|
2 | 2 | #[allow(unused)] |
3 | 3 | pub use crate::gcp_triggers_ee::*; |
4 | 4 |
|
| 5 | +use serde_json::value::RawValue; |
| 6 | +use sqlx::prelude::FromRow; |
| 7 | +use serde::{Deserialize, Serialize}; |
| 8 | +use std::collections::HashMap; |
| 9 | +use sqlx::types::Json as SqlxJson; |
| 10 | + |
5 | 11 | #[cfg(not(feature = "private"))] |
6 | 12 | use { |
7 | 13 | crate::db::{ApiAuthed, DB}, |
8 | 14 | crate::trigger_helpers::TriggerJobArgs, |
9 | 15 | axum::{extract::Request, Router}, |
10 | 16 | http::HeaderMap, |
11 | | - serde::{Deserialize, Serialize}, |
12 | | - serde_json::value::RawValue, |
13 | | - sqlx::prelude::FromRow, |
14 | | - sqlx::types::Json as SqlxJson, |
15 | | - std::collections::HashMap, |
16 | 17 | windmill_common::db::UserDB, |
17 | 18 | windmill_common::worker::to_raw_value, |
18 | 19 | windmill_common::{ |
@@ -134,7 +135,6 @@ pub fn gcp_push_route_handler() -> Router { |
134 | 135 | } |
135 | 136 |
|
136 | 137 | #[derive(FromRow, Deserialize, Serialize, Debug)] |
137 | | -#[cfg(not(feature = "private"))] |
138 | 138 | pub struct GcpTrigger { |
139 | 139 | pub gcp_resource_path: String, |
140 | 140 | pub subscription_id: String, |
@@ -163,7 +163,7 @@ pub struct GcpTrigger { |
163 | 163 | #[serde(skip_serializing_if = "Option::is_none")] |
164 | 164 | pub auto_acknowledge_msg: Option<bool>, |
165 | 165 | } |
166 | | -#[cfg(not(feature = "private"))] |
| 166 | + |
167 | 167 | impl TriggerJobArgs<String> for GcpTrigger { |
168 | 168 | fn v1_payload_fn(payload: String) -> HashMap<String, Box<RawValue>> { |
169 | 169 | HashMap::from([("payload".to_string(), to_raw_value(&payload))]) |
|
0 commit comments