renaming svix-agent to svix-webhook-bridge

Author: svix-onelson

webhook-bridge/Cargo.lock

@@ -1,8 +1,8 @@
 [workspace]
 members = [
     "generic-queue",
-    "svix-agent-types",
-    "svix-agent",
-    "svix-agent-plugin-generic",
-    "svix-agent-plugin-webhook-receiver",
+    "svix-webhook-bridge-types",
+    "svix-webhook-bridge",
+    "svix-webhook-bridge-plugin-queue-consumer",
+    "svix-webhook-bridge-plugin-webhook-receiver",
 ]

webhook-bridge/Cargo.toml

@@ -23,28 +23,28 @@ WORKDIR /app
 COPY Cargo.toml .
 COPY Cargo.lock .
 COPY generic-queue/Cargo.toml generic-queue/
-COPY svix-agent-types/Cargo.toml svix-agent-types/
-COPY svix-agent-plugin-generic/Cargo.toml svix-agent-plugin-generic/
-COPY svix-agent-plugin-webhook-receiver/Cargo.toml svix-agent-plugin-webhook-receiver/
-COPY svix-agent/Cargo.toml svix-agent/
+COPY svix-webhook-bridge-types/Cargo.toml svix-webhook-bridge-types/
+COPY svix-webhook-bridge-plugin-queue-consumer/Cargo.toml svix-webhook-bridge-plugin-queue-consumer/
+COPY svix-webhook-bridge-plugin-webhook-receiver/Cargo.toml svix-webhook-bridge-plugin-webhook-receiver/
+COPY svix-webhook-bridge/Cargo.toml svix-webhook-bridge/
 RUN set -ex ;\
         mkdir generic-queue/src ;\
-        mkdir svix-agent-plugin-generic/src ;\
-        mkdir svix-agent-plugin-webhook-receiver/src ;\
-        mkdir svix-agent-types/src ;\
-        mkdir svix-agent/src ;\
+        mkdir svix-webhook-bridge-plugin-queue-consumer/src ;\
+        mkdir svix-webhook-bridge-plugin-webhook-receiver/src ;\
+        mkdir svix-webhook-bridge-types/src ;\
+        mkdir svix-webhook-bridge/src ;\
         echo '' > generic-queue/src/lib.rs ;\
-        echo '' > svix-agent-plugin-generic/src/lib.rs ;\
-        echo '' > svix-agent-plugin-webhook-receiver/src/lib.rs ;\
-        echo '' > svix-agent-types/src/lib.rs ;\
-        echo 'fn main() { println!("Dummy!"); }' > svix-agent/src/main.rs ;\
+        echo '' > svix-webhook-bridge-plugin-queue-consumer/src/lib.rs ;\
+        echo '' > svix-webhook-bridge-plugin-webhook-receiver/src/lib.rs ;\
+        echo '' > svix-webhook-bridge-types/src/lib.rs ;\
+        echo 'fn main() { println!("Dummy!"); }' > svix-webhook-bridge/src/main.rs ;\
         cargo build --release ;\
         rm -rf \
           generic-queue/src \
-          svix-agent-plugin-generic/src \
-          svix-agent-plugin-webhook-receiver/src \
-          svix-agent-types/src \
-          svix-agent/src
+          svix-webhook-bridge-plugin-queue-consumer/src \
+          svix-webhook-bridge-plugin-webhook-receiver/src \
+          svix-webhook-bridge-types/src \
+          svix-webhook-bridge/src
 
 COPY . .
 # touching the lib.rs/main.rs ensures cargo rebuilds them instead of considering them already built.
@@ -68,7 +68,8 @@ RUN apt-get update ;\
 
 USER appuser
 
-COPY --from=build /app/target/release/svix-agent /usr/local/bin/svix-agent
+COPY --from=build /app/target/release/svix-webhook-bridge /usr/local/bin/svix-webhook-bridge
 
-# Will fail if there's no `svix-agent.yaml` in the CWD or `SVIX_AGENT_CFG` is not set to a valid path to a config
-CMD ["svix-agent"]
+# Will fail if there's no `svix-webhook-bridge.yaml` in the CWD or `SVIX_WEBHOOK_BRIDGE_CFG` is not set to a valid
+# path to a config.
+CMD ["svix-webhook-bridge"]

webhook-bridge/Dockerfile

@@ -1,23 +1,23 @@
-# Svix Agent
+# Svix Webhook Bridge
 
 This service subscribes to a queue or stream and forwards each item to Svix when a valid message is found.
 
 ## Usage
 
 ```
-svix-agent -c path/to/svix-agent.yaml
+svix-webhook-bridge -c path/to/svix-webhook-bridge.yaml
 ```
 
 ## Configuration
 
-> For an annotated sample configuration see [the example config](svix-agent.example.yaml).
+> For an annotated sample configuration see [the example config](svix-webhook-bridge.example.yaml).
 
-`svix-agent` is organized in terms of "plugins" which are tasks that run in tandem.
-Each plugin represents a unit of work performed while the agent while it runs.
+`svix-webhook-bridge` is organized in terms of "plugins" which are tasks that run in tandem.
+Each plugin represents a unit of work performed while the service runs.
 
-Presently there are 2 "plugins" available for `svix-agent`.
+Presently there are 2 "plugins" available for `svix-webhook-bridge`.
 
-### svix-agent-plugin-generic
+### svix-webhook-bridge-plugin-queue-consumer
 
 This plugin consumes messages from message queues to and forwards them to Svix to create messages.
 
@@ -56,7 +56,7 @@ Messages received by these consumers must follow an expected format:
 For detail on the `message` field, see: <https://api.svix.com/docs#tag/Message/operation/v1.message.create>
 
 Important to note that queues, exchanges, topics, or what have you, should be created and configured independently,
-prior to using the agent plugin. There's nothing in place to automatically create these resources.
+prior to using the plugin. There's nothing in place to automatically create these resources.
 The plugin will only try (and fail) to read from the stream in such a case.
 
 
@@ -129,7 +129,7 @@ Note that the SQS consumer requires credentials to be set as environment vars:
 - `AWS_ACCESS_KEY_ID`
 - `AWS_SECRET_ACCESS_KEY`
 
-> This incidentally means all SQS consumers configured for a given `svix-agent` will need to share these details.
+> This incidentally means all SQS consumers configured for a given `svix-webhook-bridge` will need to share these details.
 
 ```yaml
 plugins:
@@ -145,12 +145,12 @@ plugins:
 ```
 
 
-### svix-agent-plugin-webhook-receiver
+### svix-webhook-bridge-plugin-webhook-receiver
 
 This plugin starts an HTTP server which accepts webhooks and forwards them to one of the supported messaging
 systems.
 
-Again, same as with `svix-agent-plugin-generic`, the supported systems are:
+Again, same as with `svix-webhook-bridge-plugin-queue-consumer`, the supported systems are:
 
 - GCP Pub/Sub
 - RabbitMQ

webhook-bridge/README.md

@@ -222,7 +222,7 @@ impl<T: 'static + Serialize + Send + Sync> TaskQueueSend<T> for GCPPubSubQueuePr
         let topic = self.client.topic(&self.topic);
 
         // Publishing to a non-existent topic will cause the publisher to wait (forever?)
-        // Giving this error will allow dependents like `svix-agent-plugin-webhook-receiver` to
+        // Giving this error will allow dependents like `svix-webhook-bridge-plugin-webhook-receiver` to
         // respond 500 immediately when this happens, instead of holding the connection open
         // indefinitely.
         if !topic.exists(None).await.map_err(QueueError::generic)? {

webhook-bridge/generic-queue/src/gcp_pubsub.rs

@@ -1,5 +1,5 @@
 [package]
-name = "svix-agent-plugin-generic"
+name = "svix-webhook-bridge-plugin-queue-consumer"
 version = "0.1.0"
 edition = "2021"
 
@@ -11,7 +11,7 @@ generic_queue = { path = "../generic-queue" }
 serde_json = "1.0"
 serde = { version = "1.0", features = ["derive"] }
 svix = "0.84.1"
-svix-agent-types = { path = "../svix-agent-types" }
+svix-webhook-bridge-types = { path = "../svix-webhook-bridge-types" }
 tokio = { version = "1", features = ["full"] }
 tokio-executor-trait = "2.1"
 tokio-reactor-trait = "1.1"

webhook-bridge/svix-agent-plugin-generic/Cargo.toml renamed to webhook-bridge/svix-webhook-bridge-plugin-queue-consumer/Cargo.toml

@@ -9,7 +9,7 @@ use generic_queue::gcp_pubsub::{
 use generic_queue::{Delivery, TaskQueueBackend, TaskQueueReceive};
 use std::time::{Duration, Instant};
 use svix::api::Svix;
-use svix_agent_types::{async_trait, Plugin};
+use svix_webhook_bridge_types::{async_trait, Plugin};
 use tracing::instrument;
 
 pub struct GCPPubSubConsumerPlugin {

webhook-bridge/svix-agent-plugin-generic/src/config.rs renamed to webhook-bridge/svix-webhook-bridge-plugin-queue-consumer/src/config.rs

@@ -10,7 +10,7 @@ use generic_queue::{
 };
 use serde::{Deserialize, Serialize};
 use svix::api::{MessageIn, PostOptions as PostOptions_, Svix};
-use svix_agent_types::{async_trait, Plugin};
+use svix_webhook_bridge_types::{async_trait, Plugin};
 
 pub mod config;
 pub use config::{