AuthorityDrift

const client = new AuthorityDrift(config: AuthorityDriftConfig);

interface AuthorityDriftConfig {
  solanaRpcEndpoint: string;
  driftEnv: DriftEnv;
  wallet?: IWalletV2;
  driftDlobServerHttpUrl?: string;
  tradableMarkets?: MarketId[];
  selectedTradeMarket?: MarketId;
  additionalDriftClientConfig?: Partial<Omit<DriftClientConfig, 'env'>>;
  priorityFeeSubscriberConfig?: Partial<PriorityFeeSubscriberConfig>;
  orderbookConfig?: {
    dlobWebSocketUrl?: string;
    orderbookGrouping?: OrderbookGrouping;
  };
}

await client.subscribe();

await client.unsubscribe();

get driftClient(): DriftClient

get authority(): PublicKey

get tradableMarkets(): MarketId[]

get oraclePriceCache(): OraclePriceLookup

get markPriceCache(): MarkPriceLookup

get userAccountCache(): UserAccountLookup

get orderbookCache(): L2WithOracleAndMarketData | null

get isGeoBlocked(): boolean

const subscription = client.onUserAccountUpdate((account) => {
  console.log('Sub-account:', account.subAccountId);
  console.log('Positions:', account.positions);
  console.log('Balances:', account.balances);
});

// Cleanup
subscription.unsubscribe();

const subscription = client.onMarkPricesUpdate((prices) => {
  const solPerpPrice = prices['perp-0'];
  console.log('SOL-PERP mark price:', solPerpPrice);
});

const subscription = client.onOraclePricesUpdate((prices) => {
  const solPrice = prices['perp-0'];
  console.log('SOL oracle price:', solPrice.price);
  console.log('Confidence:', solPrice.confidence);
});

const subscription = client.onOrderbookUpdate((orderbook) => {
  console.log('Bids:', orderbook.bids);
  console.log('Asks:', orderbook.asks);
  console.log('Best bid:', orderbook.bestBidPrice);
  console.log('Best ask:', orderbook.bestAskPrice);
});

const result = await client.createUserAndDeposit({
  depositAmount: BigNum.from(100, 6), // 100 USDC
  depositSpotMarketIndex: 0,
  newAccountName: 'Main Account',
  referrerName: 'my-referrer',
});

console.log('Transaction:', result.txSig);
console.log('User:', result.user);

await client.deposit({
  subAccountId: 0,
  amount: BigNum.from(50, 6), // 50 USDC
  spotMarketIndex: 0,
});

await client.withdraw({
  subAccountId: 0,
  amount: BigNum.from(25, 6), // 25 USDC
  spotMarketIndex: 0,
  isBorrow: false,
  isMax: false,
});

// Market order
await client.openPerpOrder({
  subAccountId: 0,
  marketIndex: 0, // SOL-PERP
  direction: PositionDirection.LONG,
  assetType: 'base',
  size: BigNum.from(10, 9), // 10 SOL
  positionMaxLeverage: 5,
  orderConfig: {
    orderType: 'market',
  },
});

// Limit order
await client.openPerpOrder({
  subAccountId: 0,
  marketIndex: 0,
  direction: PositionDirection.LONG,
  assetType: 'base',
  size: BigNum.from(10, 9),
  positionMaxLeverage: 5,
  orderConfig: {
    orderType: 'limit',
    limitPrice: BigNum.from(100, 6),
  },
});

const quote = await client.getSwapQuote({
  fromMarketIndex: 1, // SOL
  toMarketIndex: 0,   // USDC
  amount: BigNum.from(1, 9), // 1 SOL
  subAccountId: 0,
  slippageBps: 50, // 0.5%
});

await client.swap({
  fromMarketIndex: 1,
  toMarketIndex: 0,
  amount: BigNum.from(1, 9),
  subAccountId: 0,
  quote,
});

await client.settleAccountPnl({
  subAccountId: 0,
});

await client.cancelOrders({
  subAccountId: 0,
  orderIds: [1, 2, 3],
});

await client.deleteUser(0); // Delete sub-account 0

const btcPerp = MarketId.createPerpMarket(1);
client.updateSelectedTradeMarket(btcPerp);

await client.updateAuthority(newWallet, activeSubAccountId);

const txParams = client.getTxParams({
  computeUnits: 200_000,
});

console.log('Priority fee:', txParams.computeUnitsPrice);

import { AuthorityDrift, MarketId, PositionDirection, BigNum } from '@drift-labs/common';

// Initialize client
const client = new AuthorityDrift({
  solanaRpcEndpoint: process.env.RPC_URL,
  driftEnv: 'mainnet-beta',
  wallet: myWallet,
  selectedTradeMarket: MarketId.createPerpMarket(0),
});

// Subscribe
await client.subscribe();

// Listen to updates
client.onUserAccountUpdate((account) => {
  console.log('Account updated:', account.subAccountId);
});

client.onMarkPricesUpdate((prices) => {
  const solPrice = prices['perp-0'];
  console.log('SOL price:', solPrice);
});

// Check if user has account
const hasAccount = Object.keys(client.userAccountCache).length > 0;

if (!hasAccount) {
  // Create account and deposit
  await client.createUserAndDeposit({
    depositAmount: BigNum.from(1000, 6), // 1000 USDC
    depositSpotMarketIndex: 0,
    newAccountName: 'Trading',
  });
}

// Open position
await client.openPerpOrder({
  subAccountId: 0,
  marketIndex: 0,
  direction: PositionDirection.LONG,
  assetType: 'base',
  size: BigNum.from(1, 9), // 1 SOL
  positionMaxLeverage: 3,
  orderConfig: {
    orderType: 'market',
  },
});

// Cleanup
await client.unsubscribe();