Skip to content

Commit 75f0af7

Browse files
committed
moved db close operation to start subscribe and fixed saveOrder
1 parent 86d25ea commit 75f0af7

File tree

4 files changed

+15
-14
lines changed

4 files changed

+15
-14
lines changed

src/arby.ts

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@ type StartArbyParams = {
3434
getCentralizedExchangeOrder$,
3535
getOpenDEXcomplete$,
3636
shutdown$,
37+
models,
38+
saveOrder$,
3739
}: GetTradeParams) => Observable<boolean>;
3840
cleanup$: ({
3941
config,
@@ -135,7 +137,6 @@ export const startArby = ({
135137
loggers,
136138
removeOpenDEXorders$,
137139
removeCEXorders$,
138-
closeDB$,
139140
CEX,
140141
})
141142
).pipe(
@@ -149,7 +150,6 @@ export const startArby = ({
149150
removeOpenDEXorders$,
150151
removeCEXorders$,
151152
CEX,
152-
closeDB$,
153153
});
154154
})
155155
);
@@ -182,8 +182,18 @@ if (!module.parent) {
182182
} else {
183183
console.log(error);
184184
}
185-
process.exit(1);
185+
closeDB$().subscribe({
186+
complete: () => {
187+
process.exit(1);
188+
},
189+
});
190+
},
191+
complete: () => {
192+
closeDB$().subscribe({
193+
complete: () => {
194+
console.log('Shutdown complete. Goodbye, Arby.');
195+
},
196+
});
186197
},
187-
complete: () => console.log('Shutdown complete. Goodbye, Arby.'),
188198
});
189199
}

src/centralized/execute-order.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ const executeCEXorder$ = ({
6161
logger.info(
6262
`Centralized exchange order finished: ${JSON.stringify(order)}`
6363
);
64-
saveOrder$({ order, logger, models });
64+
saveOrder$({ order, logger, models }).subscribe();
6565
}),
6666
catchError((e, caught) => {
6767
logger.warn(`Failed to execute CEX order: ${e}. Retrying in 1000ms`);

src/opendex/catch-error.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import { Logger, Loggers } from '../logger';
1010
import { errorCodes, errors } from '../opendex/errors';
1111
import { GetCleanupParams } from '../trade/cleanup';
1212
import { removeOpenDEXorders$ } from './remove-orders';
13-
import { closeDB$ } from '../db/db';
1413

1514
const catchOpenDEXerror = (
1615
loggers: Loggers,
@@ -74,7 +73,6 @@ const catchOpenDEXerror = (
7473
loggers,
7574
removeOpenDEXorders$,
7675
removeCEXorders$,
77-
closeDB$,
7876
CEX,
7977
}).pipe(ignoreElements()),
8078
timer(RETRY_INTERVAL)

src/trade/cleanup.ts

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,6 @@ type GetCleanupParams = {
4747
orderId: string
4848
) => Observable<Order>
4949
) => Observable<unknown>;
50-
closeDB$: () => Observable<void>;
5150
CEX: Exchange;
5251
};
5352

@@ -56,7 +55,6 @@ const getCleanup$ = ({
5655
loggers,
5756
removeOpenDEXorders$,
5857
removeCEXorders$,
59-
closeDB$,
6058
CEX,
6159
}: GetCleanupParams): Observable<unknown> => {
6260
const retryOnError = (logger: Logger, source: Observable<any>) => {
@@ -79,11 +77,6 @@ const getCleanup$ = ({
7977
const retryOnErrorOpenDEX = curriedRetryOnError(loggers.opendex);
8078
const retryonErrorCEX = curriedRetryOnError(loggers.centralized);
8179
return combineLatest(
82-
closeDB$().pipe(
83-
tap(() => {
84-
loggers.db.info('DB has been closed');
85-
})
86-
),
8780
removeOpenDEXorders$({
8881
config,
8982
getXudClient$,

0 commit comments

Comments
 (0)