Add price and graduation information from DBC

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

api/server.go

@@ -12,14 +12,15 @@ import (
 	"strconv"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
 	comms "bridgerton.audius.co/api/comms"
 	"bridgerton.audius.co/api/dbv1"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/config"
 	"bridgerton.audius.co/esindexer"
 	"bridgerton.audius.co/logging"
 	"bridgerton.audius.co/solana/spl"
 	"bridgerton.audius.co/solana/spl/programs/claimable_tokens"
+	"bridgerton.audius.co/solana/spl/programs/meteora_dbc"
 	"bridgerton.audius.co/solana/spl/programs/reward_manager"
 	"bridgerton.audius.co/trashid"
 	"github.com/AudiusProject/audiusd/pkg/rewards"
@@ -149,6 +150,10 @@ func NewApiServer(config config.Config) *ApiServer {
 	if err != nil {
  panic(err)
 	}
+	meteoraDbcClient := meteora_dbc.NewClient(
+ solanaRpc,
+ logger,
+	)
 
 	esClient, err := esindexer.Dial(config.EsUrl)
 	if err != nil {
@@ -202,6 +207,7 @@ func NewApiServer(config config.Config) *ApiServer {
  metricsCollector: metricsCollector,
  birdeyeClient: birdeye.New(config.BirdeyeToken),
  solanaRpcClient: solanaRpc,
+ meteoraDbcClient: meteoraDbcClient,
 	}
 
 	// Set up a custom decoder for HashIds so they can be parsed in lists
@@ -563,7 +569,7 @@ func NewApiServer(config config.Config) *ApiServer {
 
 type BirdeyeClient interface {
 	GetTokenOverview(ctx context.Context, mint string, frames string) (*birdeye.TokenOverview, error)
-	GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error)
+	GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error)
 }
 
 type ApiServer struct {
@@ -592,6 +598,7 @@ type ApiServer struct {
 	metricsCollector *MetricsCollector
 	birdeyeClient BirdeyeClient
 	solanaRpcClient *rpc.Client
+	meteoraDbcClient *meteora_dbc.Client
 }
 
 func (app *ApiServer) home(c *fiber.Ctx) error {

api/swagger/swagger-v1.yaml

@@ -5148,6 +5148,7 @@ components:
  - v24hUSD
  - vHistory24h
  - members
+ - dynamicBondingCurve
  properties:
  address:
  type: string
@@ -5353,6 +5354,26 @@ components:
  type: integer
  description: The number of Audius users holding the coin
  example: 10000
+ dynamicBondingCurve:
+ type: object
+ description: Information about the dynamic bonding curve if one exists for the Coin
+ required:
+ - pool
+ - priceUSD
+ - curveProgress
+ properties:
+ pool:
+ type: string
+ description: Address of the bonding curve pool
+ example: "2AAsAwNPTNBk5N466xyPiwqdgbc5WLbDTdnn9gVuDKaN" 
+ priceUSD:
+ type: number
+ description: Current price in USD
+ example: 0.000029571022098881748
+ curveProgress:
+ type: number
+ description: Progress along the bonding curve (0.0 - 1.0)
+ example: 0.75
  coin_insights_response:
  type: object
  properties:

api/v1_coin_insights.go

@@ -1,18 +1,27 @@
 package api
 
 import (
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
+	"github.com/gagliardetto/solana-go"
 	"github.com/gofiber/fiber/v2"
 	"github.com/jackc/pgx/v5"
 )
 
 type ArtistCoinInsights struct {
 	birdeye.TokenOverview
 	MembersStatsRow
+	DynamicBondingCurve *DynamicBondingCurveInsights `json:"dynamicBondingCurve"`
 }
 
 type MembersStatsRow struct {
-	Members int `json:"members"`
+	DbcPool *string `db:"dbc_pool" json:"-"`
+	Members int `json:"members"`
+}
+
+type DynamicBondingCurveInsights struct {
+	Pool string `json:"pool"`
+	PriceUSD float64 `json:"priceUSD"`
+	CurveProgress float64 `json:"curveProgress"`
 }
 
 func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
@@ -24,9 +33,16 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
 	}
 
 	sql := `
- SELECT COUNT(DISTINCT user_id) AS members
- FROM sol_user_balances
- WHERE mint = @mint AND balance > 0
+ SELECT 
+ dbc_pool,
+ COUNT(DISTINCT sol_user_balances.user_id) AS members
+ FROM artist_coins
+ LEFT JOIN sol_user_balances 
+ ON sol_user_balances.mint = artist_coins.mint
+ AND sol_user_balances.balance > 0
+ WHERE artist_coins.mint = @mint
+ GROUP BY dbc_pool
+ LIMIT 1
 	`
 
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
@@ -56,6 +72,48 @@ func (app *ApiServer) v1CoinInsights(c *fiber.Ctx) error {
  TokenOverview: *overview,
 	}
 
+	if insights.DbcPool == nil || *insights.DbcPool == "" {
+ // No DBC pool, return early
+ return c.JSON(fiber.Map{
+ "data": insights,
+ })
+	}
+
+	dbcPool := solana.MustPublicKeyFromBase58(*insights.DbcPool)
+
+	dbcPrice, err := app.meteoraDbcClient.GetQuotePrice(
+ c.Context(),
+ dbcPool,
+ overview.Decimals,
+ 8, // Audio has 8 decimals
+	)
+	if err != nil {
+ return err
+	}
+
+	dbcProgress, err := app.meteoraDbcClient.GetPoolCurveProgress(
+ c.Context(),
+ dbcPool,
+	)
+	if err != nil {
+ return err
+	}
+
+	prices, err := app.birdeyeClient.GetPrices(
+ c.Context(),
+ []string{app.solanaConfig.MintAudio.String()},
+	)
+	if err != nil {
+ return err
+	}
+	audioPrice := prices[app.solanaConfig.MintAudio.String()].Value
+
+	insights.DynamicBondingCurve = &DynamicBondingCurveInsights{
+ Pool: *insights.DbcPool,
+ PriceUSD: dbcPrice * audioPrice,
+ CurveProgress: dbcProgress,
+	}
+
 	return c.JSON(fiber.Map{
  "data": insights,
 	})

api/v1_coin_insights_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"bridgerton.audius.co/api/birdeye"
+	"bridgerton.audius.co/birdeye"
 	"bridgerton.audius.co/database"
 	"github.com/stretchr/testify/assert"
 )
@@ -29,7 +29,7 @@ func (m *mockBirdeyeClient) GetTokenOverview(ctx context.Context, mint string, f
 	return nil, fmt.Errorf("token not found")
 }
 
-func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*birdeye.TokenPriceMap, error) {
+func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (birdeye.TokenPriceMap, error) {
 	prices := make(birdeye.TokenPriceMap)
 	for _, mint := range mints {
  switch mint {
@@ -45,7 +45,7 @@ func (m *mockBirdeyeClient) GetPrices(ctx context.Context, mints []string) (*bir
  return nil, fmt.Errorf("price not found for mint %s", mint)
  }
 	}
-	return &prices, nil
+	return prices, nil
 }
 
 func TestGetCoinInsights(t *testing.T) {

api/v1_users_coin.go

@@ -109,7 +109,7 @@ func (app *ApiServer) v1UsersCoin(c *fiber.Ctx) error {
 	rows, err := app.pool.Query(c.Context(), sql, pgx.NamedArgs{
  "user_id": app.getUserId(c),
  "mint": params.Mint,
- "price": (*prices)[params.Mint].Value,
+ "price": prices[params.Mint].Value,
 	})
 	if err != nil {
  return err

api/v1_users_coins.go

@@ -59,8 +59,8 @@ func (app *ApiServer) v1UsersCoins(c *fiber.Ctx) error {
  return fmt.Errorf("failed to get prices: %w", err)
 	}
 
-	pricesRows := make([]string, 0, len(*prices))
-	for mint, price := range *prices {
+	pricesRows := make([]string, 0, len(prices))
+	for mint, price := range prices {
  pricesRows = append(pricesRows, fmt.Sprintf("('%s', %f)", mint, price.Value))
 	}
 

api/birdeye/client.go → birdeye/client.go

@@ -149,7 +149,7 @@ type TokenPriceData struct {
 // Map from mint to token price data
 type TokenPriceMap map[string]TokenPriceData
 
-func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap, error) {
+func (c *Client) GetPrices(ctx context.Context, mints []string) (TokenPriceMap, error) {
 	result := make(TokenPriceMap)
 
 	mintsToFetch := make([]string, 0, len(mints))
@@ -161,7 +161,7 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  }
 	}
 	if len(mintsToFetch) == 0 {
- return &result, nil
+ return result, nil
 	}
 
 	url := fmt.Sprintf("https://public-api.birdeye.so/defi/multi_price?list_address=%s", strings.Join(mintsToFetch, ","))
@@ -195,5 +195,5 @@ func (c *Client) GetPrices(ctx context.Context, mints []string) (*TokenPriceMap,
  result[mint] = priceData
 	}
 
-	return &result, nil
+	return result, nil
 }

database/dbpool.go

@@ -0,0 +1,18 @@
+package database
+
+import (
+	"context"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+)
+
+type DbPool interface {
+	Acquire(context.Context) (*pgxpool.Conn, error)
+	Begin(context.Context) (pgx.Tx, error)
+	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
+	Query(context.Context, string, ...any) (pgx.Rows, error)
+	QueryRow(context.Context, string, ...any) pgx.Row
+	Close()
+}

ddl/migrations/0157_artist_coin_names.sql

@@ -1,2 +1,2 @@
 ALTER TABLE artist_coins
- ADD COLUMN name TEXT NOT NULL DEFAULT '';
+ ADD COLUMN IF NOT EXISTS name TEXT NOT NULL DEFAULT '';

ddl/migrations/0158_artist_coin_dbc_pool.sql

@@ -0,0 +1,2 @@
+ALTER TABLE artist_coins
+ ADD COLUMN IF NOT EXISTS dbc_pool TEXT DEFAULT NULL;

ddl/migrations/0159_artist_coin_stats.sql

@@ -0,0 +1,44 @@
+CREATE TABLE IF NOT EXISTS artist_coin_stats (
+ mint TEXT PRIMARY KEY,
+ market_cap DOUBLE PRECISION,
+ fdv DOUBLE PRECISION,
+ liquidity DOUBLE PRECISION,
+ last_trade_unix_time BIGINT,
+ last_trade_human_time TEXT,
+ price DOUBLE PRECISION,
+ history_24h_price DOUBLE PRECISION,
+ price_change_24h_percent DOUBLE PRECISION,
+ unique_wallet_24h INTEGER,
+ unique_wallet_history_24h INTEGER,
+ unique_wallet_24h_change_percent DOUBLE PRECISION,
+ total_supply DOUBLE PRECISION,
+ circulating_supply DOUBLE PRECISION,
+ holder INTEGER,
+ trade_24h INTEGER,
+ trade_history_24h INTEGER,
+ trade_24h_change_percent DOUBLE PRECISION,
+ sell_24h INTEGER,
+ sell_history_24h INTEGER,
+ sell_24h_change_percent DOUBLE PRECISION,
+ buy_24h INTEGER,
+ buy_history_24h INTEGER,
+ buy_24h_change_percent DOUBLE PRECISION,
+ v_24h DOUBLE PRECISION,
+ v_24h_usd DOUBLE PRECISION,
+ v_history_24h DOUBLE PRECISION,
+ v_history_24h_usd DOUBLE PRECISION,
+ v_24h_change_percent DOUBLE PRECISION,
+ v_buy_24h DOUBLE PRECISION,
+ v_buy_24h_usd DOUBLE PRECISION,
+ v_buy_history_24h DOUBLE PRECISION,
+ v_buy_history_24h_usd DOUBLE PRECISION,
+ v_buy_24h_change_percent DOUBLE PRECISION,
+ v_sell_24h DOUBLE PRECISION,
+ v_sell_24h_usd DOUBLE PRECISION,
+ v_sell_history_24h DOUBLE PRECISION,
+ v_sell_history_24h_usd DOUBLE PRECISION,
+ v_sell_24h_change_percent DOUBLE PRECISION,
+ number_markets INTEGER,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);

ddl/migrations/0160_artist_coin_pools.sql

@@ -0,0 +1,19 @@
+CREATE TABLE IF NOT EXISTS artist_coin_pools (
+ address TEXT NOT NULL PRIMARY KEY,
+ base_mint TEXT NOT NULL,
+ quote_mint TEXT,
+ token_decimals INTEGER,
+ base_reserve NUMERIC,
+ quote_reserve NUMERIC,
+ migration_base_threshold NUMERIC,
+ migration_quote_threshold NUMERIC,
+ protocol_quote_fee NUMERIC,
+ partner_quote_fee NUMERIC,
+ creator_base_fee NUMERIC,
+ creator_quote_fee NUMERIC,
+ price DOUBLE PRECISION,
+ curve_progress DOUBLE PRECISION,
+ is_migrated BOOLEAN,
+ created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
+);