migrating some cosmos stuff

aronchick · aronchick · commit 326891faebf4 · 2025-03-28T09:15:45.000+01:00
diff --git a/utility_containers/event-puller/.cspell/custom-dictionary.txt b/utility_containers/event-puller/.cspell/custom-dictionary.txt
@@ -1,10 +1,13 @@
 AKIA
+azcosmos
 bacalhau
 bacalhauproject
 bubbletea
 charmbracelet
+containerenv
 datestamp
 DHGR
+dockerenv
 dotenv
 FLDYOBFDVW
 FLDYOBFGMGMNNMZ
@@ -13,6 +16,7 @@ glyphicon
 GOARCH
 godotenv
 joho
+kubepods
 ldflags
 LEGA
 lipgloss
diff --git a/utility_containers/event-puller/cosmos_pusher.go b/utility_containers/event-puller/cosmos_pusher.go
@@ -0,0 +1 @@
+package main
diff --git a/utility_containers/event-puller/main.go b/utility_containers/event-puller/main.go
@@ -1485,7 +1485,7 @@ func (m *model) addLog(format string, args ...interface{}) {
 }
 
 // Initialize Cosmos DB client
-func initCosmosClient(ctx context.Context) (*azcosmos.Client, bool, error) {
+func initCosmosClient(_ context.Context) (*azcosmos.Client, bool, error) {
 	endpoint := os.Getenv("COSMOS_ENDPOINT")
 	key := os.Getenv("COSMOS_KEY")
 
@@ -1510,7 +1510,7 @@ func initCosmosClient(ctx context.Context) (*azcosmos.Client, bool, error) {
 }
 
 // Get a container client for Cosmos DB
-func getCosmosContainer(client *azcosmos.Client, ctx context.Context) (*azcosmos.ContainerClient, error) {
+func getCosmosContainer(client *azcosmos.Client, _ context.Context) (*azcosmos.ContainerClient, error) {
 	databaseName := os.Getenv("COSMOS_DATABASE")
 	containerName := os.Getenv("COSMOS_CONTAINER")
 

Original file line number	Diff line number	Diff line change
`@@ -1485,7 +1485,7 @@ func (m *model) addLog(format string, args ...interface{}) {`
`1485`	`1485`	`}`
`1486`	`1486`
`1487`	`1487`	`// Initialize Cosmos DB client`
`1488`		`-func initCosmosClient(ctx context.Context) (*azcosmos.Client, bool, error) {`
	`1488`	`+func initCosmosClient(_ context.Context) (*azcosmos.Client, bool, error) {`
`1489`	`1489`	`endpoint := os.Getenv("COSMOS_ENDPOINT")`
`1490`	`1490`	`key := os.Getenv("COSMOS_KEY")`
`1491`	`1491`
`@@ -1510,7 +1510,7 @@ func initCosmosClient(ctx context.Context) (*azcosmos.Client, bool, error) {`
`1510`	`1510`	`}`
`1511`	`1511`
`1512`	`1512`	`// Get a container client for Cosmos DB`
`1513`		`-func getCosmosContainer(client azcosmos.Client, ctx context.Context) (azcosmos.ContainerClient, error) {`
	`1513`	`+func getCosmosContainer(client azcosmos.Client, _ context.Context) (azcosmos.ContainerClient, error) {`
`1514`	`1514`	`databaseName := os.Getenv("COSMOS_DATABASE")`
`1515`	`1515`	`containerName := os.Getenv("COSMOS_CONTAINER")`
`1516`	`1516`