Samuel Tariku
e49ff366d5
- Added new notification handling in the wallet service to notify admins when wallet balances are low or insufficient. - Created a new file for wallet notifications and moved relevant functions from the wallet service to this new file. - Updated the wallet service to publish wallet events including wallet type. - Refactored the client code to improve readability and maintainability. - Enhanced the bet handler to support pagination and status filtering for bets. - Updated routes and handlers for user search functionality to improve clarity and organization. - Modified cron job scheduling to comment out unused jobs for clarity. - Updated the WebSocket broadcast to include wallet type in notifications. - Adjusted the makefile to include Kafka in the docker-compose setup for local development.
148 lines
3.0 KiB
SQL
148 lines
3.0 KiB
SQL
-- Users
|
|
INSERT INTO users (
|
|
id,
|
|
first_name,
|
|
last_name,
|
|
email,
|
|
phone_number,
|
|
password,
|
|
role,
|
|
email_verified,
|
|
phone_verified,
|
|
created_at,
|
|
updated_at,
|
|
suspended,
|
|
company_id
|
|
)
|
|
VALUES (
|
|
5,
|
|
'Test',
|
|
'Veli',
|
|
'test.veli@example.com',
|
|
NULL,
|
|
crypt('password@123', gen_salt('bf'))::bytea,
|
|
'customer',
|
|
TRUE,
|
|
FALSE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP,
|
|
FALSE,
|
|
1
|
|
),
|
|
(
|
|
6,
|
|
'Kirubel',
|
|
'Kibru',
|
|
'modernkibru@gmail.com',
|
|
NULL,
|
|
crypt('password@123', gen_salt('bf'))::bytea,
|
|
'customer',
|
|
TRUE,
|
|
FALSE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP,
|
|
FALSE,
|
|
1
|
|
) ON CONFLICT (id) DO
|
|
UPDATE
|
|
SET first_name = EXCLUDED.first_name,
|
|
last_name = EXCLUDED.last_name,
|
|
email = EXCLUDED.email,
|
|
phone_number = EXCLUDED.phone_number,
|
|
password = EXCLUDED.password,
|
|
role = EXCLUDED.role,
|
|
email_verified = EXCLUDED.email_verified,
|
|
phone_verified = EXCLUDED.phone_verified,
|
|
created_at = EXCLUDED.created_at,
|
|
updated_at = EXCLUDED.updated_at,
|
|
suspended = EXCLUDED.suspended,
|
|
company_id = EXCLUDED.company_id;
|
|
INSERT INTO wallets (
|
|
id,
|
|
balance,
|
|
is_withdraw,
|
|
is_bettable,
|
|
is_transferable,
|
|
user_id,
|
|
type,
|
|
currency,
|
|
is_active,
|
|
created_at,
|
|
updated_at
|
|
)
|
|
VALUES (
|
|
5,
|
|
10000,
|
|
TRUE,
|
|
TRUE,
|
|
TRUE,
|
|
5,
|
|
'regular_wallet',
|
|
'ETB',
|
|
TRUE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP
|
|
),
|
|
(
|
|
6,
|
|
5000,
|
|
FALSE,
|
|
TRUE,
|
|
TRUE,
|
|
5,
|
|
'static_wallet',
|
|
'ETB',
|
|
TRUE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP
|
|
),
|
|
(
|
|
7,
|
|
1000000,
|
|
TRUE,
|
|
TRUE,
|
|
TRUE,
|
|
6,
|
|
'regular_wallet',
|
|
'ETB',
|
|
TRUE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP
|
|
),
|
|
(
|
|
8,
|
|
5000,
|
|
FALSE,
|
|
TRUE,
|
|
TRUE,
|
|
6,
|
|
'static_wallet',
|
|
'ETB',
|
|
TRUE,
|
|
CURRENT_TIMESTAMP,
|
|
CURRENT_TIMESTAMP
|
|
) ON CONFLICT (id) DO
|
|
UPDATE
|
|
SET balance = EXCLUDED.balance,
|
|
is_withdraw = EXCLUDED.is_withdraw,
|
|
is_bettable = EXCLUDED.is_bettable,
|
|
is_transferable = EXCLUDED.is_transferable,
|
|
user_id = EXCLUDED.user_id,
|
|
type = EXCLUDED.type,
|
|
currency = EXCLUDED.currency,
|
|
is_active = EXCLUDED.is_active,
|
|
created_at = EXCLUDED.created_at,
|
|
updated_at = EXCLUDED.updated_at;
|
|
-- Customer Wallets
|
|
INSERT INTO customer_wallets (
|
|
id,
|
|
customer_id,
|
|
regular_wallet_id,
|
|
static_wallet_id
|
|
)
|
|
VALUES (2, 5, 5, 6),
|
|
(3, 6, 7, 8) ON CONFLICT (id) DO
|
|
UPDATE
|
|
SET customer_id = EXCLUDED.customer_id,
|
|
regular_wallet_id = EXCLUDED.regular_wallet_id,
|
|
static_wallet_id = EXCLUDED.static_wallet_id; |