diff --git a/cmd/connector-user-actions-timescale/Dockerfile b/cmd/connector-user-actions-timescale/Dockerfile deleted file mode 100644 index 4c9f43566..000000000 --- a/cmd/connector-user-actions-timescale/Dockerfile +++ /dev/null @@ -1,12 +0,0 @@ - -FROM fluidity/build-container:latest - -WORKDIR /usr/local/src/fluidity/cmd/connector-user-actions-timescale - -RUN make - -ENTRYPOINT [ \ - "wait-for-amqp", \ - "wait-for-database.sh", \ - "./connector-user-actions-timescale.o" \ -] diff --git a/cmd/connector-user-actions-timescale/Makefile b/cmd/connector-user-actions-timescale/Makefile deleted file mode 100644 index 58d88b426..000000000 --- a/cmd/connector-user-actions-timescale/Makefile +++ /dev/null @@ -1,4 +0,0 @@ - -REPO := connector-user-actions-timescale - -include ../../golang.mk diff --git a/cmd/connector-user-actions-timescale/README.md b/cmd/connector-user-actions-timescale/README.md deleted file mode 100644 index 69ffbf439..000000000 --- a/cmd/connector-user-actions-timescale/README.md +++ /dev/null @@ -1,25 +0,0 @@ - -# User Actions Timescale Connector - -Write user actions to the Timescale database. - -## Environment variables - -| Name | Description -|--------------------------|------------------------------------------------------------------------------| -| `FLU_WORKER_ID` | Worker ID used to identify the application in logging and to the AMQP queue. | -| `FLU_DEBUG` | Toggle debug messages produced by any application using the debug logger. | -| `FLU_AMQP_QUEUE_ADDR` | AMQP queue address connected to to receive and send messages down. | -| `FLU_TIMESCALE_URI` | Timescale URI to use when writing user actions to the database. | - -## Building - - make build - -## Testing - - make test - -## Docker - - make docker diff --git a/cmd/connector-user-actions-timescale/main.go b/cmd/connector-user-actions-timescale/main.go deleted file mode 100644 index a3e5e239f..000000000 --- a/cmd/connector-user-actions-timescale/main.go +++ /dev/null @@ -1,16 +0,0 @@ -package main - -import ( - database "github.com/fluidity-money/fluidity-app/lib/databases/timescale/user-actions" - queue "github.com/fluidity-money/fluidity-app/lib/queues/user-actions" -) - -func main() { - go queue.UserActionsEthereum(database.InsertUserAction) - - queue.BufferedUserActionsSolana(func(bufferedUserActions queue.BufferedUserAction) { - for _, userAction := range bufferedUserActions.UserActions { - database.InsertUserAction(userAction) - } - }) -}