add transaction-by-id service in rust

Cargo.toml

@@ -14,6 +14,7 @@ members = [
 	"services/request-create",
 	"services/requests-by-account",
 	"services/rule",
+	"services/transaction-by-id",
 	"tests",
 ]
 

docker/dev/transaction-by-id.Dockerfile

@@ -1,17 +1,39 @@
-FROM mxfactorial/go-base:v1 as builder
+FROM rust:latest as builder
 
-COPY . .
+WORKDIR /app
 
-WORKDIR /app/services/transaction-by-id
+COPY . ./
 
-RUN go build -o transaction-by-id ./cmd
+RUN rustup target add x86_64-unknown-linux-musl
+RUN apt update && \
+	apt install -y musl-tools perl make
+RUN update-ca-certificates
 
-FROM golang:alpine
+ENV USER=transaction-by-id
+ENV UID=10007
 
-WORKDIR /app
+RUN adduser \
+    --disabled-password \
+    --gecos "" \
+    --home "/nonexistent" \
+    --shell "/sbin/nologin" \
+    --no-create-home \
+    --uid "${UID}" \
+    "${USER}"
+
+RUN USER=root cargo build \
+		--manifest-path=services/transaction-by-id/Cargo.toml \
+		--target x86_64-unknown-linux-musl \
+		--release
 
-COPY --from=builder /app/services/transaction-by-id/transaction-by-id .
+FROM alpine
+
+COPY --from=builder /etc/passwd /etc/passwd
+COPY --from=builder /etc/group /etc/group
+COPY --from=builder /app/target/x86_64-unknown-linux-musl/release/transaction-by-id /usr/local/bin
 
 EXPOSE 10007
 
-CMD ["/app/transaction-by-id"]
+USER transaction-by-id:transaction-by-id
+
+CMD [ "/usr/local/bin/transaction-by-id" ]

project.yaml

@@ -491,13 +491,13 @@ services:
         - READINESS_CHECK_PATH
         - RETURN_RECORD_LIMIT
   transaction-by-id:
-    runtime: go1.x
+    runtime: rust1.x
     min_code_cov: null
     type: app
     local_dev: true
     params: []
     deploy: true
-    build_src_path: cmd
+    build_src_path: null
     dependents: []
     env_var:
       set:

services/transaction-by-id/Cargo.toml

@@ -0,0 +1,18 @@
+[package]
+name = "transaction-by-id"
+version = "0.1.0"
+edition = "2021"
+rust-version.workspace = true
+
+[dependencies]
+axum = "0.7.4"
+tracing = "0.1.40"
+tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
+tokio = { version = "1.35.1", features = ["macros", "rt-multi-thread"] }
+shutdown = { path = "../../crates/shutdown" }
+pg = { path = "../../crates/pg" }
+service = { path = "../../crates/service" }
+types = { path = "../../crates/types" }
+
+[target.x86_64-unknown-linux-musl.dependencies]
+openssl = { version = "0.10", features = ["vendored"] }

services/transaction-by-id/makefile

@@ -1,6 +1,6 @@
 RELATIVE_PROJECT_ROOT_PATH=$(shell REL_PATH="."; while [ $$(ls "$$REL_PATH" | grep project.yaml | wc -l | xargs) -eq 0 ]; do REL_PATH="$$REL_PATH./.."; done; printf '%s' "$$REL_PATH")
 include $(RELATIVE_PROJECT_ROOT_PATH)/make/shared.mk
-include $(RELATIVE_PROJECT_ROOT_PATH)/make/go.mk
+include $(RELATIVE_PROJECT_ROOT_PATH)/make/rust.mk
 
 TRANSACTION_BY_ID_PORT=$(shell yq '.services["$(APP_NAME)"].env_var.set.TRANSACTION_BY_ID_PORT.default' $(PROJECT_CONF))
 TRANSACTION_BY_ID_URL=$(HOST):$(TRANSACTION_BY_ID_PORT)
@@ -11,13 +11,21 @@ TEST_TRANSACTION_ID=2
 TEST_EVENT='{"auth_account":"$(TEST_AUTH_ACCOUNT)","account_name":"$(TEST_AUTH_ACCOUNT)","id":"$(TEST_TRANSACTION_ID)"}'
 TEST_SENDER_ACCOUNT=$(TEST_ACCOUNT)
 
-run:
-	@$(DOCKER_ENV_VARS) \
-		TEST_EVENT=$(TEST_EVENT) \
-		go run ./cmd/main.go
+start:
+	@$(MAKE) get-secrets ENV=local
+	nohup cargo watch --env-file $(ENV_FILE) -w src -w $(RELATIVE_PROJECT_ROOT_PATH)/crates -x run >> $(NOHUP_LOG) &
+
+start-alone:
+	rm -f $(NOHUP_LOG)
+	$(MAKE) -C $(MIGRATIONS_DIR) run
+	$(MAKE) start
+	tail -F $(NOHUP_LOG)
+
+stop:
+	$(MAKE) -C $(RELATIVE_PROJECT_ROOT_PATH) stop
 
 invoke-local:
-	@curl -s -d $(TEST_EVENT) $(TRANSACTION_BY_ID_URL) | yq -o=json
+	@curl -s -H 'Content-Type: application/json' -d $(TEST_EVENT) $(TRANSACTION_BY_ID_URL) | yq -o=json
 
 demo:
 	@printf "*** request to %s at %s\n" $(SUB_PATH) $(TRANSACTION_BY_ID_URL)

services/transaction-by-id/src/main.rs

@@ -0,0 +1,123 @@
+use axum::{
+    extract::{Json, State},
+    http::StatusCode,
+    routing::{get, post},
+    Router,
+};
+use pg::postgres::{ConnectionPool, DB};
+use service::Service;
+use shutdown::shutdown_signal;
+use std::{env, net::ToSocketAddrs};
+use tokio::net::TcpListener;
+use types::request_response::{IntraTransaction, QueryById};
+
+// used by lambda to test for service availability
+const READINESS_CHECK_PATH: &str = "READINESS_CHECK_PATH";
+
+async fn handle_event(
+    State(pool): State<ConnectionPool>,
+    event: Json<QueryById>,
+) -> Result<axum::Json<IntraTransaction>, StatusCode> {
+    let client_request = event.0;
+
+    let svc = Service::new(pool.get_conn().await);
+
+    let transaction_id = client_request.id.parse::<i32>().unwrap();
+
+    let approvals = svc
+        .get_approvals_by_transaction_id(transaction_id)
+        .await
+        .map_err(|e| {
+            tracing::error!("error: {}", e);
+            StatusCode::INTERNAL_SERVER_ERROR
+        })?;
+
+    // test for account in approvals
+    if approvals
+        .clone()
+        .0
+        .into_iter()
+        .filter(|a| a.account_name == client_request.auth_account)
+        .count()
+        == 0
+    {
+        tracing::error!("transaction not found");
+        return Err(StatusCode::BAD_REQUEST);
+    }
+
+    // test for missing approval times
+    if approvals
+        .clone()
+        .0
+        .into_iter()
+        .filter(|a| a.approval_time.is_none())
+        .count()
+        > 0
+    {
+        tracing::error!("transaction not found");
+        return Err(StatusCode::BAD_REQUEST);
+    }
+
+    let transaction_items = svc
+        .get_transaction_items_by_transaction_id(transaction_id)
+        .await
+        .map_err(|e| {
+            tracing::error!("error: {}", e);
+            StatusCode::INTERNAL_SERVER_ERROR
+        })?;
+
+    let mut transaction = svc
+        .get_transaction_by_id(transaction_id)
+        .await
+        .map_err(|e| {
+            tracing::error!("error: {}", e);
+            StatusCode::INTERNAL_SERVER_ERROR
+        })?;
+
+    transaction.build(transaction_items, approvals).unwrap();
+
+    let intra_transaction_request = IntraTransaction::new(client_request.auth_account, transaction);
+
+    Ok(axum::Json(intra_transaction_request))
+}
+
+#[tokio::main]
+async fn main() {
+    tracing_subscriber::fmt::init();
+
+    let readiness_check_path = env::var(READINESS_CHECK_PATH)
+        .unwrap_or_else(|_| panic!("{READINESS_CHECK_PATH} variable assignment"));
+
+    let conn_uri = DB::create_conn_uri_from_env_vars();
+
+    let pool = DB::new_pool(&conn_uri).await;
+
+    let app = Router::new()
+        .route("/", post(handle_event))
+        .route(
+            readiness_check_path.as_str(),
+            get(|| async { StatusCode::OK }),
+        )
+        .with_state(pool);
+
+    let hostname_or_ip = env::var("HOSTNAME_OR_IP").unwrap_or("0.0.0.0".to_string());
+
+    let port = env::var("TRANSACTION_BY_ID_PORT").unwrap_or("10007".to_string());
+
+    let serve_addr = format!("{hostname_or_ip}:{port}");
+
+    let mut addrs_iter = serve_addr.to_socket_addrs().unwrap_or(
+        format!("{hostname_or_ip}:{port}")
+            .to_socket_addrs()
+            .unwrap(),
+    );
+
+    let addr = addrs_iter.next().unwrap();
+
+    tracing::info!("listening on {}", addr);
+
+    axum::serve(TcpListener::bind(addr).await.unwrap(), app)
+        .with_graceful_shutdown(shutdown_signal())
+        .await
+        .unwrap();
+}