trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #303 from drift-labs/master

Browse Source 
bump staging
This commit is contained in:
jack
2024-12-06 14:05:22 +11:00
committed by GitHub
parent de750046db bad158bb7c
commit 54bb542d2a
3 changed files with 95 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
.github/workflows/mainnet-beta.yml vendored Normal file
View File

@@ -0,0 +1,69 @@
name: DLOB Build Image And Deploy
on:
push:
branches: [mainnet-beta]
jobs:
build:
runs-on: ubicloud
steps:
- name: Checkout Code
uses: actions/checkout@v3
with:
submodules: 'recursive'
- name: Configure AWS credentials
uses: aws-actions/configure-aws-credentials@master
with:
aws-access-key-id: ${{ secrets.AWS_ACCESS_KEY_PROD }}
aws-secret-access-key: ${{ secrets.AWS_SECRET_KEY_PROD }}
aws-region: ${{ secrets.EKS_PROD_REGION }}
- name: Log in to Amazon ECR
id: login-ecr
uses: aws-actions/amazon-ecr-login@v2
- name: Build and push
uses: docker/build-push-action@v6
env:
ECR_REGISTRY: ${{ steps.login-ecr.outputs.registry }}
ECR_REPOSITORY: dlob-server
IMAGE_TAG: ${{ github.sha }}
BRANCH_NAME: ${{ github.ref_name }}
with:
context: .
push: true
tags: |
${{ env.ECR_REGISTRY }}/${{ env.ECR_REPOSITORY }}:${{ env.IMAGE_TAG }}-${{ env.BRANCH_NAME }}-amd64
${{ env.ECR_REGISTRY }}/${{ env.ECR_REPOSITORY }}:latest-${{ env.BRANCH_NAME }}-amd64
deploy:
runs-on: ubicloud
needs: [build]
steps:
- name: Configure AWS credentials
uses: aws-actions/configure-aws-credentials@master
with:
aws-access-key-id: ${{ secrets.AWS_ACCESS_KEY_PROD }}
aws-secret-access-key: ${{ secrets.AWS_SECRET_KEY_PROD }}
aws-region: ${{ secrets.EKS_PROD_REGION }}
- name: Install kubectl
uses: azure/setup-kubectl@v3
with:
version: 'v1.30.0'
- name: Configure AWS EKS Credentials
run: aws eks update-kubeconfig --name ${{ secrets.EKS_PROD_CLUSTER_NAME }} --region ${{ secrets.EKS_PROD_REGION }} --role-arn ${{ secrets.EKS_PROD_DEPLOY_ROLE }}
- name: Restart deployment
env:
BRANCH_NAME: ${{ github.ref_name }}
run: |
kubectl get deployments -n $BRANCH_NAME -o name | grep '^deployment.apps/dlob-publisher-app' | xargs -I {} kubectl rollout restart {} -n $BRANCH_NAME
kubectl rollout restart -n $BRANCH_NAME deployment/dlob-server-app
kubectl rollout restart -n $BRANCH_NAME deployment/dlob-server-lite-app
kubectl rollout restart -n $BRANCH_NAME deployment/dlob-ws-connection-manager-app
kubectl rollout restart -n $BRANCH_NAME deployment/dlob-trades-publisher-app
kubectl rollout restart -n $BRANCH_NAME deployment/dlob-priority-fees-publisher-app

2
.github/workflows/master.yml vendored
View File

@@ -36,7 +36,7 @@ jobs:
context: .
push: true
tags: |
${{ env.ECR_REGISTRY }}/${{ env.ECR_REPOSITORY }}:${{ env.IMAGE_TAG }}
${{ env.ECR_REGISTRY }}/${{ env.ECR_REPOSITORY }}:${{ env.IMAGE_TAG }}-${{ env.BRANCH_NAME }}-amd64
${{ env.ECR_REGISTRY }}/${{ env.ECR_REPOSITORY }}:latest-${{ env.BRANCH_NAME }}-amd64
deploy:

45
src/publishers/dlobPublisher.ts
View File

@@ -324,29 +324,34 @@ const main = async () => {
let accountSubscription: DriftClientSubscriptionConfig;
let slotSource: SlotSource;
// NOTE: disable GRPC for general driftClient subscriptions until we can reliably subscribe
// to multiple streams. Currently this causes the nodes to start killing connections.
//
// USE_GRPC=true will override websocket
if (useGrpc) {
accountSubscription = {
type: 'grpc',
resubTimeoutMs: 30_000,
grpcConfigs: {
endpoint,
token,
channelOptions: {
'grpc.keepalive_time_ms': 10_000,
'grpc.keepalive_timeout_ms': 1_000,
'grpc.keepalive_permit_without_calls': 1,
},
},
};
// if (useGrpc) {
// accountSubscription = {
// type: 'grpc',
// resubTimeoutMs: 30_000,
// grpcConfigs: {
// endpoint,
// token,
// channelOptions: {
// 'grpc.keepalive_time_ms': 10_000,
// 'grpc.keepalive_timeout_ms': 1_000,
// 'grpc.keepalive_permit_without_calls': 1,
// },
// },
// };
slotSubscriber = new SlotSubscriber(connection);
await slotSubscriber.subscribe();
// slotSubscriber = new SlotSubscriber(connection);
// await slotSubscriber.subscribe();
slotSource = {
getSlot: () => slotSubscriber!.getSlot(),
};
} else if (!useWebsocket) {
// slotSource = {
// getSlot: () => slotSubscriber!.getSlot(),
// };
// }
if (!useWebsocket) {
bulkAccountLoader = new BulkAccountLoader(
connection,
stateCommitment,