New Github organization

ylem-co · Sep 2, 2024 · b4584a6 · b4584a6
1 parent 2a9c02f
commit b4584a6
Show file tree

Hide file tree

Showing 77 changed files with 157 additions and 133 deletions.
diff --git a/README.md b/README.md
@@ -7,8 +7,8 @@
   ![Static Badge](https://img.shields.io/badge/checks-passing-green)
   ![Static Badge](https://img.shields.io/badge/Go-1.21-black)
   ![Static Badge](https://img.shields.io/badge/React-18.3.1-black)
-  <a href="https://github.com/datamin-io/ylem?tab=Apache-2.0-1-ov-file">![Static Badge](https://img.shields.io/badge/license-Apache%202.0-black)</a>
-  <a href="https://github.com/datamin-io/ylem/tags">![Static Badge](https://img.shields.io/badge/tag-v0.0.1_pre_release-black)</a>
+  <a href="https://github.com/ylem-co/ylem?tab=Apache-2.0-1-ov-file">![Static Badge](https://img.shields.io/badge/license-Apache%202.0-black)</a>
+  <a href="https://github.com/ylem-co/ylem/tags">![Static Badge](https://img.shields.io/badge/tag-v0.0.1_pre_release-black)</a>
   <a href="https://ylem.co" target="_blank">![Static Badge](https://img.shields.io/badge/website-ylem.co-black)</a>
   <a href="https://join.slack.com/t/datamincommunity/shared_invite/zt-2nawzl6h0-qqJ0j7Vx_AEHfnB45xJg2Q" target="_blank">![Static Badge](https://img.shields.io/badge/community-join%20Slack-black)</a>
 </div>

diff --git a/backend/integrations/api/AuthorizeHubspot.go b/backend/integrations/api/AuthorizeHubspot.go
@@ -1,7 +1,7 @@
 package api
 
 import (
-	hubspotclient "github.com/datamin-io/hubspot-client"
+	hubspotclient "github.com/ylem-co/hubspot-client"
 	log "github.com/sirupsen/logrus"
 	"golang.org/x/oauth2"
 	"net/http"

diff --git a/backend/integrations/api/AuthorizeSalesforce.go b/backend/integrations/api/AuthorizeSalesforce.go
@@ -1,7 +1,7 @@
 package api
 
 import (
-	"github.com/datamin-io/salesforce-client"
+	"github.com/ylem-co/salesforce-client"
 	log "github.com/sirupsen/logrus"
 	"golang.org/x/oauth2"
 	"net/http"

diff --git a/backend/integrations/api/Common.go b/backend/integrations/api/Common.go
@@ -6,8 +6,8 @@ import (
 	"fmt"
 	"database/sql"
 	"encoding/json"
-	hubspotclient "github.com/datamin-io/hubspot-client"
-	"github.com/datamin-io/salesforce-client"
+	hubspotclient "github.com/ylem-co/hubspot-client"
+	"github.com/ylem-co/salesforce-client"
 	log "github.com/sirupsen/logrus"
 	"net/http"
 	"ylem_integrations/config"

diff --git a/backend/integrations/api/DescribeSQLIntegrationTable.go b/backend/integrations/api/DescribeSQLIntegrationTable.go
@@ -11,7 +11,7 @@ import (
 	"ylem_integrations/services/sql"
 
 	validation "github.com/go-ozzo/ozzo-validation"
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	log "github.com/sirupsen/logrus"
 	"github.com/go-ozzo/ozzo-validation/is"
 	"github.com/gorilla/mux"

diff --git a/backend/integrations/api/GetHubspotIntegrationPrivate.go b/backend/integrations/api/GetHubspotIntegrationPrivate.go
@@ -3,7 +3,7 @@ package api
 import (
 	"encoding/json"
 	"github.com/asaskevich/govalidator"
-	hubspotclient "github.com/datamin-io/hubspot-client"
+	hubspotclient "github.com/ylem-co/hubspot-client"
 	"github.com/gorilla/mux"
 	log "github.com/sirupsen/logrus"
 	"golang.org/x/oauth2"

diff --git a/backend/integrations/api/GetSalesforceIntegrationPrivate.go b/backend/integrations/api/GetSalesforceIntegrationPrivate.go
@@ -3,7 +3,7 @@ package api
 import (
 	"encoding/json"
 	"github.com/asaskevich/govalidator"
-	salesforceclient "github.com/datamin-io/salesforce-client"
+	salesforceclient "github.com/ylem-co/salesforce-client"
 	"github.com/gorilla/mux"
 	log "github.com/sirupsen/logrus"
 	"golang.org/x/oauth2"

diff --git a/backend/integrations/api/ShowSQLIntegrationDatabases.go b/backend/integrations/api/ShowSQLIntegrationDatabases.go
@@ -11,7 +11,7 @@ import (
 	"ylem_integrations/services"
 
 	validation "github.com/go-ozzo/ozzo-validation"
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	log "github.com/sirupsen/logrus"
 	"github.com/go-ozzo/ozzo-validation/is"
 	"github.com/gorilla/mux"

diff --git a/backend/integrations/api/ShowSQLIntegrationTables.go b/backend/integrations/api/ShowSQLIntegrationTables.go
@@ -11,7 +11,7 @@ import (
 	"ylem_integrations/services"
 
 	validation "github.com/go-ozzo/ozzo-validation"
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	log "github.com/sirupsen/logrus"
 	"github.com/go-ozzo/ozzo-validation/is"
 	"github.com/gorilla/mux"

diff --git a/backend/integrations/cli/command/kafka/kafka_consumer.go b/backend/integrations/cli/command/kafka/kafka_consumer.go
@@ -4,7 +4,7 @@ import (
 	"ylem_integrations/config"
 	"ylem_integrations/services"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	log "github.com/sirupsen/logrus"
 	"github.com/urfave/cli/v2"
 	"github.com/lovoo/goka"

diff --git a/backend/integrations/entities/SQLIntegration.go b/backend/integrations/entities/SQLIntegration.go
@@ -6,7 +6,7 @@ import (
 	"ylem_integrations/config"
 	"ylem_integrations/services/aws/kms"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 const IntegrationTypeSQL = "sql"

diff --git a/backend/integrations/go.mod b/backend/integrations/go.mod
@@ -9,7 +9,6 @@ require (
 	github.com/aws/aws-sdk-go v1.42.4
 	github.com/aws/aws-sdk-go-v2/config v1.18.19
 	github.com/aws/aws-sdk-go-v2/service/kms v1.16.3
-	github.com/datamin-io/es-sql-client v0.0.0-20220606104308-38201558d3a6
 	github.com/go-resty/resty/v2 v2.11.0
 	github.com/go-sql-driver/mysql v1.8.0
 	github.com/golang-migrate/migrate/v4 v4.15.2
@@ -68,9 +67,6 @@ require (
 	github.com/aws/smithy-go v1.13.5 // indirect
 	github.com/cpuguy83/go-md2man/v2 v2.0.0 // indirect
 	github.com/danieljoos/wincred v1.1.2 // indirect
-	github.com/datamin-io/hubspot-client v0.0.0-20220919103229-bfc2d8bf2be2 // indirect
-	github.com/datamin-io/salesforce-client v0.0.0-20221109155817-c7501eb3d7b4 // indirect
-	github.com/datamin-io/shared-messaging v0.0.0-20240604214722-03c8146b4530 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/dvsekhvalnov/jose2go v1.6.0 // indirect
 	github.com/eapache/go-resiliency v1.2.0 // indirect
@@ -112,6 +108,10 @@ require (
 	github.com/russross/blackfriday/v2 v2.0.1 // indirect
 	github.com/shurcooL/sanitized_anchor_name v1.0.0 // indirect
 	github.com/syndtr/goleveldb v1.0.0 // indirect
+	github.com/ylem-co/es-sql-client v0.0.0-20240902163915-13ef8638db5d // indirect
+	github.com/ylem-co/hubspot-client v0.0.0-20240902164341-00f6a99cfdd1 // indirect
+	github.com/ylem-co/salesforce-client v0.0.0-20240902165912-6a570283e8d5 // indirect
+	github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 // indirect
 	github.com/zeebo/xxh3 v1.0.2 // indirect
 	go.opencensus.io v0.24.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.47.0 // indirect

diff --git a/backend/integrations/go.sum b/backend/integrations/go.sum
@@ -456,16 +456,6 @@ github.com/d2g/dhcp4server v0.0.0-20181031114812-7d4a0a7f59a5/go.mod h1:Eo87+Kg/
 github.com/d2g/hardwareaddr v0.0.0-20190221164911-e7d9fbe030e4/go.mod h1:bMl4RjIciD2oAxI7DmWRx6gbeqrkoLqv3MV0vzNad+I=
 github.com/danieljoos/wincred v1.1.2 h1:QLdCxFs1/Yl4zduvBdcHB8goaYk9RARS2SgLLRuAyr0=
 github.com/danieljoos/wincred v1.1.2/go.mod h1:GijpziifJoIBfYh+S7BbkdUTU4LfM+QnGqR5Vl2tAx0=
-github.com/datamin-io/es-sql-client v0.0.0-20220606104308-38201558d3a6 h1:JBo/5qi9LpAO3R8N0FyerCLiFSGfdm7Bi2TOc74xzDg=
-github.com/datamin-io/es-sql-client v0.0.0-20220606104308-38201558d3a6/go.mod h1:nhRUvmtSePoOcTN36G9sYscAnCcVk96O5LEylERbFs8=
-github.com/datamin-io/hubspot-client v0.0.0-20220914140024-d250f3035b6d h1:ZJGR8ri3t7t1AVb3Rss0aeTIZ7q7AIem7BB0fT5+STI=
-github.com/datamin-io/hubspot-client v0.0.0-20220914140024-d250f3035b6d/go.mod h1:pd4lRzTO8pZ/788yNTg1xQgW8xpmN6BZ8BHvmmwKip0=
-github.com/datamin-io/hubspot-client v0.0.0-20220919103229-bfc2d8bf2be2 h1:7FNiGEQgXsuC8/uOx38rWh9mbBhD0ijEbkc3c72lWXo=
-github.com/datamin-io/hubspot-client v0.0.0-20220919103229-bfc2d8bf2be2/go.mod h1:BtjViZlN+y1usdIzm6LMYmuDIgyjweRmp/Ghud+5JkM=
-github.com/datamin-io/salesforce-client v0.0.0-20221109155817-c7501eb3d7b4 h1:1OA2xL7gZRF4JsMDfNuq+ExCyozXVYtwr6gPrpfzuTM=
-github.com/datamin-io/salesforce-client v0.0.0-20221109155817-c7501eb3d7b4/go.mod h1:RZB/EO1djWVr5YXWg3Vm5HgdYeXBKoDJfK7YJ0rK99Y=
-github.com/datamin-io/shared-messaging v0.0.0-20240604214722-03c8146b4530 h1:IZfTqC18sfnmx8Og5nz0XW4nsvx1Jn2RBB44I35oWfM=
-github.com/datamin-io/shared-messaging v0.0.0-20240604214722-03c8146b4530/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -1333,6 +1323,24 @@ github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415/go.mod h1:
 github.com/xeipuuv/gojsonschema v0.0.0-20180618132009-1d523034197f/go.mod h1:5yf86TLmAcydyeJq5YvxkGPE2fm/u4myDekKRoLuqhs=
 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
+github.com/ylem-co/es-sql-client v0.0.0-20220606104308-38201558d3a6 h1:JBo/5qi9LpAO3R8N0FyerCLiFSGfdm7Bi2TOc74xzDg=
+github.com/ylem-co/es-sql-client v0.0.0-20220606104308-38201558d3a6/go.mod h1:nhRUvmtSePoOcTN36G9sYscAnCcVk96O5LEylERbFs8=
+github.com/ylem-co/es-sql-client v0.0.0-20240902163915-13ef8638db5d h1:ArBR5qFQXokDSXa5ecQZ37uODV5TiANmfj3t3awSw8U=
+github.com/ylem-co/es-sql-client v0.0.0-20240902163915-13ef8638db5d/go.mod h1:UR6ao0wJyacQ14og88CP3sxvYnN4Ls4IEY9zRKDqeNM=
+github.com/ylem-co/hubspot-client v0.0.0-20220914140024-d250f3035b6d h1:ZJGR8ri3t7t1AVb3Rss0aeTIZ7q7AIem7BB0fT5+STI=
+github.com/ylem-co/hubspot-client v0.0.0-20220914140024-d250f3035b6d/go.mod h1:pd4lRzTO8pZ/788yNTg1xQgW8xpmN6BZ8BHvmmwKip0=
+github.com/ylem-co/hubspot-client v0.0.0-20220919103229-bfc2d8bf2be2 h1:7FNiGEQgXsuC8/uOx38rWh9mbBhD0ijEbkc3c72lWXo=
+github.com/ylem-co/hubspot-client v0.0.0-20220919103229-bfc2d8bf2be2/go.mod h1:BtjViZlN+y1usdIzm6LMYmuDIgyjweRmp/Ghud+5JkM=
+github.com/ylem-co/hubspot-client v0.0.0-20240902164341-00f6a99cfdd1 h1:RR7OB1jiTbPnx6ULZ8EA2MC70FmJJJWk9dRBF/Ig4WE=
+github.com/ylem-co/hubspot-client v0.0.0-20240902164341-00f6a99cfdd1/go.mod h1:cny7gvvuFFNgFqPRbrUAQkgtIn6g3xOSBxrF9rpHjBQ=
+github.com/ylem-co/salesforce-client v0.0.0-20221109155817-c7501eb3d7b4 h1:1OA2xL7gZRF4JsMDfNuq+ExCyozXVYtwr6gPrpfzuTM=
+github.com/ylem-co/salesforce-client v0.0.0-20221109155817-c7501eb3d7b4/go.mod h1:RZB/EO1djWVr5YXWg3Vm5HgdYeXBKoDJfK7YJ0rK99Y=
+github.com/ylem-co/salesforce-client v0.0.0-20240902165912-6a570283e8d5 h1:qpfC7r7BlGqLJtF/+tWJEAyw2O4xw+O/Yo1UpV4jXRU=
+github.com/ylem-co/salesforce-client v0.0.0-20240902165912-6a570283e8d5/go.mod h1:D64P2ZA3RuKJbOAwO8DcPOtA24E3w1w9Ezg9YQOvSn8=
+github.com/ylem-co/shared-messaging v0.0.0-20240604214722-03c8146b4530 h1:IZfTqC18sfnmx8Og5nz0XW4nsvx1Jn2RBB44I35oWfM=
+github.com/ylem-co/shared-messaging v0.0.0-20240604214722-03c8146b4530/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 h1:EMlJO+cJp5mC+bNGeq/leKaRNPXMnN/LESGKTIpr+FQ=
+github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4/go.mod h1:OAQr4N1aBobOY7KC4D4bRXWmdMl4SHxsKSs8yBniIoM=
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

diff --git a/backend/integrations/services/es/es.go b/backend/integrations/services/es/es.go
@@ -2,7 +2,7 @@ package es
 
 import (
 	"context"
-	essqlclient "github.com/datamin-io/es-sql-client"
+	essqlclient "github.com/ylem-co/es-sql-client"
 	"github.com/go-resty/resty/v2"
 )
 

diff --git a/backend/integrations/services/hubspot.go b/backend/integrations/services/hubspot.go
@@ -1,7 +1,7 @@
 package services
 
 import (
-	"github.com/datamin-io/hubspot-client"
+	"github.com/ylem-co/hubspot-client"
 	"ylem_integrations/config"
 )
 

diff --git a/backend/integrations/services/runner.go b/backend/integrations/services/runner.go
@@ -4,7 +4,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"reflect"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 func ProcessMessage(task interface{}) {

diff --git a/backend/integrations/services/salesforce.go b/backend/integrations/services/salesforce.go
@@ -1,7 +1,7 @@
 package services
 
 import (
-	"github.com/datamin-io/salesforce-client"
+	"github.com/ylem-co/salesforce-client"
 	"ylem_integrations/config"
 )
 

diff --git a/backend/pipelines/cli/command/trigger_listener.go b/backend/pipelines/cli/command/trigger_listener.go
@@ -7,7 +7,7 @@ import (
 	"github.com/lovoo/goka"
 	"github.com/urfave/cli/v2"
 	log "github.com/sirupsen/logrus"
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 var triggerListenerStartHandler cli.ActionFunc = func(ctx *cli.Context) error {

diff --git a/backend/pipelines/go.mod b/backend/pipelines/go.mod
@@ -5,7 +5,6 @@ go 1.21
 require (
 	github.com/adhocore/gronx v0.2.6
 	github.com/asaskevich/govalidator v0.0.0-20210307081110-f21760c49a8d
-	github.com/datamin-io/shared-messaging v0.0.0-20240717175742-c78b09b209c0
 	github.com/go-resty/resty/v2 v2.7.0
 	github.com/go-sql-driver/mysql v1.6.0
 	github.com/golang-migrate/migrate/v4 v4.15.1
@@ -42,6 +41,7 @@ require (
 	github.com/russross/blackfriday/v2 v2.0.1 // indirect
 	github.com/shurcooL/sanitized_anchor_name v1.0.0 // indirect
 	github.com/syndtr/goleveldb v1.0.0 // indirect
+	github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 // indirect
 	go.uber.org/atomic v1.6.0 // indirect
 	golang.org/x/crypto v0.0.0-20210921155107-089bfa567519 // indirect
 	golang.org/x/net v0.0.0-20211029224645-99673261e6eb // indirect

diff --git a/backend/pipelines/go.sum b/backend/pipelines/go.sum
@@ -292,16 +292,6 @@ github.com/d2g/dhcp4 v0.0.0-20170904100407-a1d1b6c41b1c/go.mod h1:Ct2BUK8SB0YC1S
 github.com/d2g/dhcp4client v1.0.0/go.mod h1:j0hNfjhrt2SxUOw55nL0ATM/z4Yt3t2Kd1mW34z5W5s=
 github.com/d2g/dhcp4server v0.0.0-20181031114812-7d4a0a7f59a5/go.mod h1:Eo87+Kg/IX2hfWJfwxMzLyuSZyxSoAug2nGa1G2QAi8=
 github.com/d2g/hardwareaddr v0.0.0-20190221164911-e7d9fbe030e4/go.mod h1:bMl4RjIciD2oAxI7DmWRx6gbeqrkoLqv3MV0vzNad+I=
-github.com/datamin-io/shared-messaging v0.0.0-20240604214722-03c8146b4530 h1:IZfTqC18sfnmx8Og5nz0XW4nsvx1Jn2RBB44I35oWfM=
-github.com/datamin-io/shared-messaging v0.0.0-20240604214722-03c8146b4530/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
-github.com/datamin-io/shared-messaging v0.0.0-20240715184048-3e8d5586e4d6 h1:0y+gly9MnHVC23jLX5hi3h4Q8IW/bBJRxqp26KLvBm4=
-github.com/datamin-io/shared-messaging v0.0.0-20240715184048-3e8d5586e4d6/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
-github.com/datamin-io/shared-messaging v0.0.0-20240715220236-72e35b8e3b39 h1:ozJGaMWMx3xno2ZcbdikHRdkc6I6wuS00mafjZwSdE0=
-github.com/datamin-io/shared-messaging v0.0.0-20240715220236-72e35b8e3b39/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
-github.com/datamin-io/shared-messaging v0.0.0-20240716200530-0aac29b06bc8 h1:jtjSaGqMj+R50w29p8iyrY2HKUDQGrM0gK8/hWsczLA=
-github.com/datamin-io/shared-messaging v0.0.0-20240716200530-0aac29b06bc8/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
-github.com/datamin-io/shared-messaging v0.0.0-20240717175742-c78b09b209c0 h1:MxPzTVjDiBbhrIWkRVNtQ9hjw5m+f6nHxwf/vaYPqlc=
-github.com/datamin-io/shared-messaging v0.0.0-20240717175742-c78b09b209c0/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@@ -967,6 +957,18 @@ github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415/go.mod h1:
 github.com/xeipuuv/gojsonschema v0.0.0-20180618132009-1d523034197f/go.mod h1:5yf86TLmAcydyeJq5YvxkGPE2fm/u4myDekKRoLuqhs=
 github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
 github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1:aYKd//L2LvnjZzWKhF00oedf4jCCReLcmhLdhm1A27Q=
+github.com/ylem-co/shared-messaging v0.0.0-20240604214722-03c8146b4530 h1:IZfTqC18sfnmx8Og5nz0XW4nsvx1Jn2RBB44I35oWfM=
+github.com/ylem-co/shared-messaging v0.0.0-20240604214722-03c8146b4530/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240715184048-3e8d5586e4d6 h1:0y+gly9MnHVC23jLX5hi3h4Q8IW/bBJRxqp26KLvBm4=
+github.com/ylem-co/shared-messaging v0.0.0-20240715184048-3e8d5586e4d6/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240715220236-72e35b8e3b39 h1:ozJGaMWMx3xno2ZcbdikHRdkc6I6wuS00mafjZwSdE0=
+github.com/ylem-co/shared-messaging v0.0.0-20240715220236-72e35b8e3b39/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240716200530-0aac29b06bc8 h1:jtjSaGqMj+R50w29p8iyrY2HKUDQGrM0gK8/hWsczLA=
+github.com/ylem-co/shared-messaging v0.0.0-20240716200530-0aac29b06bc8/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240717175742-c78b09b209c0 h1:MxPzTVjDiBbhrIWkRVNtQ9hjw5m+f6nHxwf/vaYPqlc=
+github.com/ylem-co/shared-messaging v0.0.0-20240717175742-c78b09b209c0/go.mod h1:mMMhSSerLwzVnqWs+gwfcbVBaEx66FzBBhq4HOlO4Iw=
+github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4 h1:EMlJO+cJp5mC+bNGeq/leKaRNPXMnN/LESGKTIpr+FQ=
+github.com/ylem-co/shared-messaging v0.0.0-20240902171028-26da5a197fd4/go.mod h1:OAQr4N1aBobOY7KC4D4bRXWmdMl4SHxsKSs8yBniIoM=
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

diff --git a/backend/pipelines/services/messaging/aggregator.go b/backend/pipelines/services/messaging/aggregator.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type AggregatorTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/api.go b/backend/pipelines/services/messaging/api.go
@@ -9,7 +9,7 @@ import (
 	"ylem_pipelines/services/ylem_integrations"
 
 	"github.com/google/uuid"
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/backend/pipelines/services/messaging/code.go b/backend/pipelines/services/messaging/code.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type CodeMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/condition.go b/backend/pipelines/services/messaging/condition.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type ConditionTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/external_trigger.go b/backend/pipelines/services/messaging/external_trigger.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type ExternalTriggerMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/factory.go b/backend/pipelines/services/messaging/factory.go
@@ -8,7 +8,7 @@ import (
 	"ylem_pipelines/helpers"
 	"ylem_pipelines/services/ylem_integrations"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/services/messaging/filter.go b/backend/pipelines/services/messaging/filter.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type FilterTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/for_each.go b/backend/pipelines/services/messaging/for_each.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type ForEachTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/gpt.go b/backend/pipelines/services/messaging/gpt.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type GptMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/merge.go b/backend/pipelines/services/messaging/merge.go
@@ -7,7 +7,7 @@ import (
 	"ylem_pipelines/app/task"
 	"ylem_pipelines/app/tasktrigger"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type MergeTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/notification.go b/backend/pipelines/services/messaging/notification.go
@@ -7,7 +7,7 @@ import (
 	"ylem_pipelines/app/task"
 	"ylem_pipelines/services/ylem_integrations"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 	"github.com/google/uuid"
 )
 

diff --git a/backend/pipelines/services/messaging/processor.go b/backend/pipelines/services/messaging/processor.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type ProcessorTaskMessageFactory struct {

diff --git a/backend/pipelines/services/messaging/query.go b/backend/pipelines/services/messaging/query.go
@@ -9,8 +9,8 @@ import (
 	"ylem_pipelines/app/task"
 	"ylem_pipelines/services/ylem_integrations"
 
-	messaging "github.com/datamin-io/shared-messaging"
 	"github.com/google/uuid"
+	messaging "github.com/ylem-co/shared-messaging"
 	lru "github.com/hashicorp/golang-lru"
 	log "github.com/sirupsen/logrus"
 )

diff --git a/backend/pipelines/services/messaging/run_pipeline.go b/backend/pipelines/services/messaging/run_pipeline.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"ylem_pipelines/app/task"
 
-	messaging "github.com/datamin-io/shared-messaging"
+	messaging "github.com/ylem-co/shared-messaging"
 )
 
 type RunPipelineMessageFactory struct {