Skip to content
This repository has been archived by the owner on Aug 16, 2023. It is now read-only.

Remove outbox transaction handler #ULMS-2507 #429

Open
wants to merge 102 commits into
base: setup-nats-consumer
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from 25 commits
Commits
Show all changes
102 commits
Select commit Hold shift + click to select a range
f7ffaae
Add handling of new events
wakeful-kitten Jul 23, 2023
97d57c7
Add a new type error
wakeful-kitten Jul 23, 2023
28f92c6
Send events to Nats instead of using transactional outbox
wakeful-kitten Jul 23, 2023
4a6c01f
Remove outbox files
wakeful-kitten Jul 25, 2023
65d27db
Add messages handling
wakeful-kitten Jul 25, 2023
ba4d684
Remove dead code
wakeful-kitten Jul 25, 2023
aae77c4
Remove dead code
wakeful-kitten Jul 25, 2023
d370e92
Add a migration to create table `nats_event_ids`
wakeful-kitten Jul 26, 2023
0492768
Update sqlx-data.json
wakeful-kitten Jul 27, 2023
a0f4c2c
Update work with `event_id`
wakeful-kitten Jul 27, 2023
fda9d1a
Rename migrations
wakeful-kitten Jul 27, 2023
7326f08
Update 20230725111239_create_table_nats_event_ids.down.sql
wakeful-kitten Jul 27, 2023
7daf02f
Update 20230725111239_create_table_nats_event_ids.down.sql
wakeful-kitten Jul 27, 2023
a4c8955
Remove outbox
wakeful-kitten Jul 27, 2023
82f5d06
Queries to table `nats_event_ids`
wakeful-kitten Jul 27, 2023
0eb88c4
Remove outbox
wakeful-kitten Jul 27, 2023
45b0a67
Update subject
wakeful-kitten Jul 27, 2023
1835e27
Remove dead code
wakeful-kitten Jul 27, 2023
62c0482
Formatting
wakeful-kitten Jul 27, 2023
914fd42
Remove an extra notification to Nats
wakeful-kitten Jul 27, 2023
2c99fb8
Update versions of svc-events and svc-nats-client
wakeful-kitten Jul 28, 2023
33a2fdd
Update CI config
wakeful-kitten Jul 28, 2023
d56e0f8
Update CI config
wakeful-kitten Jul 28, 2023
4b82936
Update CI config
wakeful-kitten Jul 28, 2023
560eb1f
Update CI
wakeful-kitten Jul 28, 2023
5784c52
Update sqlx-data.json
wakeful-kitten Jul 28, 2023
f157905
Revert CI config changes
wakeful-kitten Jul 28, 2023
8c72a87
Simplification
wakeful-kitten Jul 28, 2023
6cf9f62
Remove extra hints for Clippy
wakeful-kitten Jul 28, 2023
471bb3a
Update sqlx-data.json
wakeful-kitten Jul 28, 2023
7c0a1a3
Update README.md
wakeful-kitten Jul 28, 2023
038d26b
Simplification
wakeful-kitten Jul 28, 2023
94bbb68
Add Janus configs in UpdateJanusConfigStageV1
wakeful-kitten Jul 28, 2023
902f41b
Remove dead code
wakeful-kitten Jul 28, 2023
1041472
Add 3rd stage
wakeful-kitten Jul 29, 2023
746eaba
Formatting
wakeful-kitten Jul 29, 2023
f236a87
Remove dead code
wakeful-kitten Jul 29, 2023
96946e8
Improve errors handling
wakeful-kitten Jul 30, 2023
e3ac416
Formatting
wakeful-kitten Jul 30, 2023
d287d09
Update migrations
wakeful-kitten Jul 30, 2023
bd121b8
Update sqlx-data.json
wakeful-kitten Jul 30, 2023
72fae4d
Use sequence instead of table to store NATS event ID
wakeful-kitten Jul 30, 2023
04ce455
Formatting
wakeful-kitten Jul 30, 2023
d0128fa
Remove dead code
wakeful-kitten Jul 30, 2023
da21c33
Fix Clippy remarks
wakeful-kitten Jul 30, 2023
ae855d7
Update README.md
wakeful-kitten Jul 30, 2023
0a41fe9
Update migrations
wakeful-kitten Jul 30, 2023
1153f1e
Update Cargo.lock
wakeful-kitten Jul 30, 2023
5ffa87a
Renaming
wakeful-kitten Jul 31, 2023
0f57b7a
Simplification
wakeful-kitten Jul 31, 2023
abffbd2
Use only one stage
wakeful-kitten Jul 31, 2023
784b86f
Store operation in event_id
wakeful-kitten Jul 31, 2023
8c40ac9
Remove StageError
wakeful-kitten Jul 31, 2023
df4478e
Move database mutations in the stage
wakeful-kitten Aug 2, 2023
c6417ae
Formatting
wakeful-kitten Aug 2, 2023
2edcd8c
Renaming
wakeful-kitten Aug 2, 2023
a02c119
Formatting
wakeful-kitten Aug 2, 2023
4ab1602
Fix linter remarks
wakeful-kitten Aug 2, 2023
80becfa
Change the event operation
wakeful-kitten Aug 2, 2023
222f822
Remove extra transaction blocks
wakeful-kitten Aug 2, 2023
1724f2c
Add a transaction block
wakeful-kitten Aug 2, 2023
d00ef24
Use a new version event `VideoGroupEventV1`
wakeful-kitten Aug 3, 2023
8f4bdcb
Update Cargo.lock
wakeful-kitten Aug 3, 2023
62aaa2c
Remove dead code
wakeful-kitten Aug 3, 2023
b03f5f0
Renaming
wakeful-kitten Aug 3, 2023
2b6c365
Formatting
wakeful-kitten Aug 3, 2023
b1f5fcd
Use VideoGroupIntentEventV1
wakeful-kitten Aug 3, 2023
a897626
Remove trait `StageHandle`
wakeful-kitten Aug 4, 2023
42259a6
Remove dead code
wakeful-kitten Aug 4, 2023
2aafd4d
Rename error
wakeful-kitten Aug 4, 2023
db8e1dd
Add task_description.md
wakeful-kitten Aug 4, 2023
6e91c55
Remove dead code
wakeful-kitten Aug 4, 2023
c03300f
Use nats_client
wakeful-kitten Aug 4, 2023
a46462d
Fix liter remarks
wakeful-kitten Aug 4, 2023
5ad6733
Use new events
wakeful-kitten Aug 4, 2023
6c50890
Update Cargo.lock
wakeful-kitten Aug 4, 2023
4b6d58d
Update tests
wakeful-kitten Aug 7, 2023
7386991
Update tests
wakeful-kitten Aug 7, 2023
05095f4
Update tests
wakeful-kitten Aug 7, 2023
b261dd4
Update tests
wakeful-kitten Aug 8, 2023
5c4de77
Update tests
wakeful-kitten Aug 8, 2023
de865dc
Revert CI config
wakeful-kitten Aug 8, 2023
78ee3f2
Remove dead code
wakeful-kitten Aug 9, 2023
6af5709
Remove dead code
wakeful-kitten Aug 9, 2023
1dec369
Move the module for work with NATS in module `db`
wakeful-kitten Aug 9, 2023
8cca756
Renaming
wakeful-kitten Aug 9, 2023
c59ebe5
Refactoring
wakeful-kitten Aug 9, 2023
7c1335c
Renaming
wakeful-kitten Aug 9, 2023
2f198fb
Add intent_event
wakeful-kitten Aug 10, 2023
6a054fd
Remove dead code
wakeful-kitten Aug 10, 2023
0ec9b7f
Formatting
wakeful-kitten Aug 10, 2023
1738673
Refactoring
wakeful-kitten Aug 10, 2023
d2cc06b
Update operation
wakeful-kitten Aug 10, 2023
0be8ec4
Remove task_description.md
wakeful-kitten Aug 10, 2023
7025c7b
Renaming
wakeful-kitten Aug 10, 2023
3f90e5a
Update migrations
wakeful-kitten Aug 10, 2023
30684b2
Renaming
wakeful-kitten Aug 10, 2023
8d0da23
Update sqlx-data.json
wakeful-kitten Aug 10, 2023
acf2c71
Fix typos
wakeful-kitten Aug 11, 2023
a343981
Refactoring
wakeful-kitten Aug 11, 2023
d59d941
Simplification
wakeful-kitten Aug 11, 2023
743d6bb
Update tests
wakeful-kitten Aug 15, 2023
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
29 changes: 12 additions & 17 deletions .github/workflows/check.yml
Original file line number Diff line number Diff line change
Expand Up @@ -30,29 +30,24 @@ jobs:
- name: Install latest stable
wakeful-kitten marked this conversation as resolved.
Show resolved Hide resolved
uses: actions-rs/toolchain@v1
with:
toolchain: stable
override: true
components: rustfmt, clippy
toolchain: stable
override: true
components: rustfmt, clippy
- uses: Swatinem/rust-cache@v1
- name: clippy
run: cargo clippy -- -D warnings
- name: fmt
run: cargo fmt -- --check
- name: Login into private registry
run: |
printf "%s" "${DOCKER_PASSWORD}" | docker login -u ${DOCKER_USERNAME} --password-stdin cr.yandex
env:
DOCKER_PASSWORD: ${{ secrets.YANDEX_DOCKER_PASSWORD }}
DOCKER_USERNAME: ${{ secrets.YANDEX_DOCKER_USERNAME }}
- name: clippy
run: cargo clippy -- -D warnings
- name: Run tests
run: cargo test
- name: Install sqlx-cli
run: cargo install sqlx-cli --version 0.6.3 --no-default-features -F native-tls,postgres
- name: Run tests
run: >
cargo sqlx database create &&
cargo sqlx migrate run &&
cargo sqlx prepare --check -- --tests &&
cargo test
- name: Run migrations and check sqlx-data.json
env:
RUST_BACKTRACE: 1
DATABASE_URL: postgres://postgres:postgres@localhost:5432/postgres
SQLX_OFFLINE: true
run: |
cargo sqlx database create
cargo sqlx migrate run
cargo sqlx prepare --check -- --tests
88 changes: 33 additions & 55 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 4 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -40,15 +40,17 @@ sqlx = { version = "0.6", features = ["offline", "postgres", "chrono", "uuid", "
svc-agent = { version = "0.21", features = ["sqlx"] }
svc-authn = { version = "0.8", features = ["jose"] }
svc-authz = "0.12"
svc-events = { version = "0.10" }
# svc-events = { version = "0.10" }
svc-events = { git = "https://github.com/foxford/svc-events", branch = "wakeful-kitten/ULMS-2507" }
svc-error = { version = "0.6", features = [
"r2d2",
"svc-agent",
"svc-authn",
"svc-authz",
"sentry-extension",
] }
svc-nats-client = { version = "0.7" }
# svc-nats-client = { version = "0.7" }
svc-nats-client = { git = "https://github.com/foxford/svc-nats-client", branch = "wakeful-kitten/ULMS-2507" }
svc-utils = { version = "0.8", features = ["cors-middleware", "authn-extractor"] }
thiserror = "1.0"
tokio = { version = "1", features = ["full"] }
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
DROP TABLE IF EXISTS nats_event_ids;
5 changes: 5 additions & 0 deletions migrations/20230725111239_create_table_nats_event_ids.up.sql
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
CREATE TABLE IF NOT EXISTS nats_event_ids (
wakeful-kitten marked this conversation as resolved.
Show resolved Hide resolved
id BIGSERIAL PRIMARY KEY NOT NULL,
entity_type TEXT NOT NULL,
created_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL
);
Loading