Elixir Chat Service

.env

@@ -54,6 +54,12 @@ CART_SERVICE_PORT=7070
 CART_SERVICE_ADDR=cartservice:${CART_SERVICE_PORT}
 CART_SERVICE_DOCKERFILE=./src/cartservice/src/Dockerfile
 
+# Chat Service
+CHAT_SERVICE_PORT=4000
+CHAT_SERVICE_HOST=chatservice
+CHAT_SERVICE_DOCKERFILE=./src/chatservice/Dockerfile
+
+
 # Checkout Service
 CHECKOUT_SERVICE_PORT=5050
 CHECKOUT_SERVICE_ADDR=checkoutservice:${CHECKOUT_SERVICE_PORT}

.gitignore

@@ -19,6 +19,7 @@ docker-compose.override.yml
 .settings
 
 bin/
+!src/chatservice/rel/overlays/bin
 obj/
 .vs/
 .vscode

docker-compose.yml

@@ -110,6 +110,33 @@ services:
         condition: service_started
     logging: *logging
 
+  # Cart service
+  chatservice:
+    image: ${IMAGE_NAME}:${DEMO_VERSION}-chatservice
+    container_name: chat-service
+    build:
+      context: ./
+      dockerfile: ${CHAT_SERVICE_DOCKERFILE}
+      cache_from:
+        - ${IMAGE_NAME}:${IMAGE_VERSION}-chatservice
+    deploy:
+      resources:
+        limits:
+          memory: 360M
+    restart: unless-stopped
+    ports:
+      - "${CHAT_SERVICE_PORT}:${CHAT_SERVICE_PORT}"
+    environment:
+      - CHAT_SERVICE_PORT
+      - OTEL_EXPORTER_OTLP_ENDPOINT=http://${OTEL_COLLECTOR_HOST}:${OTEL_COLLECTOR_PORT_HTTP}
+      - OTEL_RESOURCE_ATTRIBUTES
+      - OTEL_SERVICE_NAME=chatservice
+      - DATABASE_URL=ecto://chat:chat@chat-db:5432/chats
+    depends_on:
+      otelcol:
+        condition: service_started
+    logging: *logging
+
   # Checkout service
   checkoutservice:
     image: ${IMAGE_NAME}:${DEMO_VERSION}-checkoutservice
@@ -323,25 +350,27 @@ services:
       - "${ENVOY_PORT}:${ENVOY_PORT}"
       - 10000:10000
     environment:
-      - FRONTEND_PORT
+      - CHAT_SERVICE_HOST
+      - CHAT_SERVICE_PORT
+      - ENVOY_PORT
+      - FLAGD_HOST
+      - FLAGD_PORT
+      - FLAGD_UI_HOST
+      - FLAGD_UI_PORT
       - FRONTEND_HOST
-      - LOCUST_WEB_HOST
-      - LOCUST_WEB_PORT
-      - GRAFANA_SERVICE_PORT
+      - FRONTEND_PORT
       - GRAFANA_SERVICE_HOST
-      - JAEGER_SERVICE_PORT
-      - JAEGER_SERVICE_HOST
-      - OTEL_COLLECTOR_HOST
+      - GRAFANA_SERVICE_PORT
       - IMAGE_PROVIDER_HOST
       - IMAGE_PROVIDER_PORT
+      - JAEGER_SERVICE_HOST
+      - JAEGER_SERVICE_PORT
+      - LOCUST_WEB_HOST
+      - LOCUST_WEB_PORT
+      - OTEL_COLLECTOR_HOST
       - OTEL_COLLECTOR_PORT_GRPC
       - OTEL_COLLECTOR_PORT_HTTP
       - OTEL_RESOURCE_ATTRIBUTES
-      - ENVOY_PORT
-      - FLAGD_HOST
-      - FLAGD_PORT
-      - FLAGD_UI_HOST
-      - FLAGD_UI_PORT
     depends_on:
       frontend:
         condition: service_started
@@ -628,6 +657,29 @@ services:
     volumes:
       - ./src/flagd:/app/data
 
+  # Postgres used by chat service
+  chat_postgres:
+    image: ${POSTGRES_IMAGE}
+    container_name: chat-db
+    user: postgres
+    deploy:
+      resources:
+        limits:
+          memory: 120M
+    restart: unless-stopped
+    environment:
+      - POSTGRES_USER=chat
+      - POSTGRES_DB=chats
+      - POSTGRES_PASSWORD=chat
+    volumes:
+      - ./src/chat_postgres/10-chat_schema.sql:/docker-entrypoint-initdb.d/10-chat_schema.sql
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -d chats -U chat"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+    logging: *logging
+
   # Kafka used by Checkout, Accounting, and Fraud Detection services
   kafka:
     image: ${IMAGE_NAME}:${DEMO_VERSION}-kafka

src/chat_postgres/10-chat_schema.sql

@@ -0,0 +1,12 @@
+-- Copyright The OpenTelemetry Authors
+-- SPDX-License-Identifier: Apache-2.0
+
+CREATE TABLE public.messages (
+    topic character varying(255),
+    name character varying(255),
+    message character varying(255),
+    sent_at timestamp(0) without time zone,
+    inserted_at timestamp(0) without time zone NOT NULL,
+    updated_at timestamp(0) without time zone NOT NULL
+);
+

src/chatservice/.formatter.exs

@@ -0,0 +1,21 @@
+# Copyright The OpenTelemetry Authors
+# SPDX-License-Identifier: Apache-2.0
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+[
+  import_deps: [:ecto, :ecto_sql, :phoenix],
+  subdirectories: ["priv/*/migrations"],
+  plugins: [Phoenix.LiveView.HTMLFormatter],
+  inputs: ["*.{heex,ex,exs}", "{config,lib,test}/**/*.{heex,ex,exs}", "priv/*/seeds.exs"]
+]

src/chatservice/.gitignore

@@ -0,0 +1,40 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where 3rd-party dependencies like ExDoc output generated docs.
+/doc/
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Temporary files, for example, from tests.
+/tmp/
+
+# Ignore package tarball (built via "mix hex.build").
+chatservice-*.tar
+
+# Ignore assets that are produced by build tools.
+/priv/static/assets/
+
+# Ignore digested assets cache.
+/priv/static/cache_manifest.json
+
+# In case you use Node.js/npm, you want to ignore these.
+npm-debug.log
+/assets/node_modules/
+
+.nix-*
+
+.elixir_ls

src/chatservice/Dockerfile

@@ -0,0 +1,107 @@
+# Copyright The OpenTelemetry Authors
+# SPDX-License-Identifier: Apache-2.0
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# Find eligible builder and runner images on Docker Hub. We use Ubuntu/Debian instead of
+# Alpine to avoid DNS resolution issues in production.
+#
+# https://hub.docker.com/r/hexpm/elixir/tags?page=1&name=ubuntu
+# https://hub.docker.com/_/ubuntu?tab=tags
+#
+#
+# This file is based on these images:
+#
+#   - https://hub.docker.com/r/hexpm/elixir/tags - for the build image
+#   - https://hub.docker.com/_/debian?tab=tags&page=1&name=bullseye-20210902-slim - for the release image
+#   - https://pkgs.org/ - resource for finding needed packages
+#   - Ex: hexpm/elixir:1.13.3-erlang-25.0-debian-bullseye-20210902-slim
+#
+ARG ELIXIR_VERSION=1.14.5
+ARG OTP_VERSION=23.0
+ARG DEBIAN_VERSION=bullseye-20210902-slim
+
+ARG BUILDER_IMAGE="hexpm/elixir:${ELIXIR_VERSION}-erlang-${OTP_VERSION}-debian-${DEBIAN_VERSION}"
+ARG RUNNER_IMAGE="debian:${DEBIAN_VERSION}"
+
+FROM ${BUILDER_IMAGE} as builder
+
+# install build dependencies
+RUN apt-get update -y && apt-get install -y build-essential git \
+    && apt-get clean && rm -f /var/lib/apt/lists/*_*
+
+# prepare build dir
+WORKDIR /app
+
+# install hex + rebar
+RUN mix local.hex --force --verbose
+RUN mix local.rebar --force --verbose
+
+# set build ENV
+ENV MIX_ENV="prod"
+
+# install mix dependencies
+COPY ./src/chatservice/mix.exs ./src/chatservice/mix.lock ./
+RUN mix deps.get --only $MIX_ENV
+RUN mkdir config
+
+# copy compile-time config files before we compile dependencies
+# to ensure any relevant config change will trigger the dependencies
+# to be re-compiled.
+COPY ./src/chatservice/config/config.exs ./src/chatservice/config/${MIX_ENV}.exs config/
+RUN mix deps.compile
+
+COPY ./src/chatservice/lib lib
+
+COPY ./src/chatservice/assets assets
+
+# Compile assets
+RUN mix assets.deploy
+
+# Compile the release
+RUN mix compile
+
+# Changes to config/runtime.exs don't require recompiling the code
+COPY ./src/chatservice/config/runtime.exs config/
+
+COPY ./src/chatservice/rel rel
+RUN mix release
+
+# start a new build stage so that the final image will only contain
+# the compiled release and other runtime necessities
+FROM ${RUNNER_IMAGE}
+
+RUN apt-get update -y && apt-get install -y libstdc++6 openssl libncurses5 locales \
+  && apt-get clean && rm -f /var/lib/apt/lists/*_*
+
+# Set the locale
+RUN sed -i '/en_US.UTF-8/s/^# //g' /etc/locale.gen && locale-gen
+
+ENV LANG en_US.UTF-8
+ENV LANGUAGE en_US:en
+ENV LC_ALL en_US.UTF-8
+
+WORKDIR "/app"
+RUN chown nobody /app
+
+# set runner ENV
+ENV MIX_ENV="prod"
+ENV SECRET_KEY_BASE="mNhoOKKxgyvBIwbtw0P23waQcvUOmusb2U1moG2I7JQ3Bt6+MlGb5ZTrHwqbqy7j"
+
+# Only copy the final release from the build stage
+COPY --from=builder --chown=nobody:root /app/_build/${MIX_ENV}/rel/chatservice ./
+
+USER nobody
+
+ENTRYPOINT ["/app/bin/server"]

src/chatservice/README.md

@@ -0,0 +1,18 @@
+# ChatService
+
+To start your Phoenix server:
+
+* Run `mix setup` to install and setup dependencies
+* Start Phoenix endpoint with `mix phx.server` or inside IEx with `iex -S mix phx.server`
+
+Now you can visit `http://localhost:4000` from your browser.
+
+Ready to run in production? Please [check our deployment guides](https://hexdocs.pm/phoenix/deployment.html).
+
+## Learn more
+
+* Official website: <https://www.phoenixframework.org/>
+* Guides: <https://hexdocs.pm/phoenix/overview.html>
+* Docs: <https://hexdocs.pm/phoenix>
+* Forum: <https://elixirforum.com/c/phoenix-forum>
+* Source: <https://github.com/phoenixframework/phoenix>

src/chatservice/assets/css/app.css

@@ -0,0 +1,17 @@
+/****
+# Copyright The OpenTelemetry Authors
+# SPDX-License-Identifier: Apache-2.0
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+****/