Skip to content

Commit 948ba70

Browse files
mPaellamPaella
committed
save
1 parent d0bc8d0 commit 948ba70

11 files changed

+240
-0
lines changed

‎typescript/packages/plugins/solana-magiceden/package.json

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
{
2+
"name": "@goat-sdk/plugin-tensor",
3+
"version": "0.0.1",
4+
"files": ["dist/**/*", "README.md", "package.json"],
5+
"scripts": {
6+
"build": "tsup",
7+
"clean": "rm -rf dist",
8+
"test": "vitest run --passWithNoTests"
9+
},
10+
"sideEffects": false,
11+
"main": "./dist/index.js",
12+
"module": "./dist/index.mjs",
13+
"types": "./dist/index.d.ts",
14+
"dependencies": {
15+
"@goat-sdk/core": "workspace:*",
16+
"@solana/web3.js": "catalog:",
17+
"zod": "catalog:"
18+
},
19+
"peerDependencies": {
20+
"@goat-sdk/core": "workspace:*"
21+
},
22+
"homepage": "https://ohmygoat.dev",
23+
"repository": {
24+
"type": "git",
25+
"url": "git+https://github.com/goat-sdk/goat.git"
26+
},
27+
"license": "MIT",
28+
"bugs": {
29+
"url": "https://github.com/goat-sdk/goat/issues"
30+
},
31+
"keywords": ["ai", "agents", "web3"]
32+
}

‎typescript/packages/plugins/solana-magiceden/src/index.ts

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
export * from "./plugin";

‎typescript/packages/plugins/solana-magiceden/src/methods/buyListing.ts

+46
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
import type { SolanaWalletClient } from "@goat-sdk/core";
2+
import { type Connection, VersionedTransaction } from "@solana/web3.js";
3+
import type { z } from "zod";
4+
import type { getBuyListingTransactionResponseSchema, getNftInfoParametersSchema } from "../parameters";
5+
import { decompileVersionedTransactionToInstructions } from "../utils/decompileVersionedTransactionToInstructions";
6+
import { getNftListings } from "./getNftListings";
7+
8+
export async function buyListing(
9+
apiKey: string | undefined,
10+
connection: Connection,
11+
walletClient: SolanaWalletClient,
12+
parameters: z.infer<typeof getNftInfoParametersSchema>,
13+
) {
14+
const nftInfo = await getNftListings(apiKey, parameters);
15+
16+
const queryParams = new URLSearchParams({
17+
buyer: walletClient.getAddress(),
18+
seller: nftInfo.seller,
19+
tokenMint: parameters.mintHash,
20+
tokenATA: nftInfo.pdaAddress,
21+
price: nftInfo.price.toString(),
22+
});
23+
24+
let data: z.infer<typeof getBuyListingTransactionResponseSchema>;
25+
try {
26+
const response = await fetch(
27+
`https://api-mainnet.magiceden.dev/v2/instructions/buy_now?${queryParams.toString()}`,
28+
{
29+
headers: {
30+
"Content-Type": "application/json",
31+
...(apiKey ? { Authorization: `Bearer ${apiKey}` } : {}),
32+
},
33+
},
34+
);
35+
36+
data = (await response.json()) as z.infer<typeof getBuyListingTransactionResponseSchema>;
37+
} catch (error) {
38+
throw new Error(`Failed to get buy listing transaction: ${error}`);
39+
}
40+
41+
const versionedTransaction = VersionedTransaction.deserialize(Buffer.from(data.v0.tx.data));
42+
const instructions = await decompileVersionedTransactionToInstructions(connection, versionedTransaction);
43+
const lookupTableAddresses = versionedTransaction.message.addressTableLookups.map((lookup) => lookup.accountKey);
44+
45+
return { versionedTransaction, instructions, lookupTableAddresses };
46+
}

‎typescript/packages/plugins/solana-magiceden/src/methods/getNftListings.ts

+27
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
import type { z } from "zod";
2+
import type { getNftInfoParametersSchema, getNftInfoResponseSchema } from "../parameters";
3+
4+
export async function getNftListings(
5+
apiKey: string | undefined,
6+
parameters: z.infer<typeof getNftInfoParametersSchema>,
7+
) {
8+
let nftInfo: z.infer<typeof getNftInfoResponseSchema>;
9+
try {
10+
const response = await fetch(
11+
`https://api-mainnet.magiceden.dev/v2/tokens/${parameters.mintHash}/listings
12+
`,
13+
{
14+
headers: {
15+
"Content-Type": "application/json",
16+
...(apiKey ? { Authorization: `Bearer ${apiKey}` } : {}),
17+
},
18+
},
19+
);
20+
21+
nftInfo = (await response.json()) as z.infer<typeof getNftInfoResponseSchema>;
22+
} catch (error) {
23+
throw new Error(`Failed to get NFT listings: ${error}`);
24+
}
25+
26+
return nftInfo[0];
27+
}

‎typescript/packages/plugins/solana-magiceden/src/parameters.ts

+45
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
import { z } from "zod";
2+
3+
export const getNftInfoParametersSchema = z.object({
4+
mintHash: z.string(),
5+
});
6+
7+
export const getNftInfoResponseSchema = z.array(
8+
z.object({
9+
pdaAddress: z.string(),
10+
auctionHouse: z.string().optional(),
11+
tokenAddress: z.string().optional(),
12+
tokenMint: z.string().optional(),
13+
seller: z.string(),
14+
sellerReferral: z.string().optional(),
15+
tokenSize: z.number().optional(),
16+
price: z.number(),
17+
priceInfo: z
18+
.object({
19+
solPrice: z.object({
20+
rawAmount: z.string(),
21+
address: z.string(),
22+
decimals: z.number(),
23+
}),
24+
})
25+
.optional(),
26+
rarity: z.any().optional(),
27+
extra: z.any().optional(),
28+
expiry: z.number().optional(),
29+
token: z.any().optional(),
30+
listingSource: z.string().optional(),
31+
}),
32+
);
33+
34+
export const getBuyListingTransactionResponseSchema = z.object({
35+
v0: z.object({
36+
tx: z.object({
37+
type: z.string(),
38+
data: z.array(z.number()),
39+
}),
40+
txSigned: z.object({
41+
type: z.string(),
42+
data: z.array(z.number()),
43+
}),
44+
}),
45+
});

‎typescript/packages/plugins/solana-magiceden/src/plugin.ts

+12
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
import type { Plugin, SolanaWalletClient } from "@goat-sdk/core";
2+
import type { Connection } from "@solana/web3.js";
3+
import { getTools } from "./tools";
4+
5+
export function solanaMagicEden(params: { connection: Connection; apiKey: string }): Plugin<SolanaWalletClient> {
6+
return {
7+
name: "solana-magiceden",
8+
supportsSmartWallets: () => false,
9+
supportsChain: (chain) => chain.type === "solana",
10+
getTools: async () => getTools(params),
11+
};
12+
}

‎typescript/packages/plugins/solana-magiceden/src/tools.ts

+28
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
import type { SolanaWalletClient } from "@goat-sdk/core";
2+
3+
import type { DeferredTool } from "@goat-sdk/core";
4+
import type { Connection } from "@solana/web3.js";
5+
import { buyListing } from "./methods/buyListing";
6+
import { getNftListings } from "./methods/getNftListings";
7+
import { getNftInfoParametersSchema } from "./parameters";
8+
9+
export function getTools({
10+
apiKey,
11+
connection,
12+
}: { apiKey?: string; connection: Connection }): DeferredTool<SolanaWalletClient>[] {
13+
const getNftListingsTool: DeferredTool<SolanaWalletClient> = {
14+
name: "get_nft_listings",
15+
description: "Gets information about a Solana NFT, from the Magic Eden API",
16+
parameters: getNftInfoParametersSchema,
17+
method: async (walletClient, parameters) => getNftListings(apiKey, parameters),
18+
};
19+
20+
const buyListingTool: DeferredTool<SolanaWalletClient> = {
21+
name: "get_buy_listing_transaction",
22+
description: "Gets a transaction to buy a Solana NFT from a listing from the Magic Eden API",
23+
parameters: getNftInfoParametersSchema,
24+
method: async (walletClient, parameters) => buyListing(apiKey, connection, walletClient, parameters),
25+
};
26+
27+
return [getNftListingsTool, buyListingTool];
28+
}

‎typescript/packages/plugins/solana-magiceden/src/utils/decompileVersionedTransactionToInstructions.ts

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
import { type DecompileArgs, TransactionMessage } from "@solana/web3.js";
2+
3+
import type { Connection, VersionedTransaction } from "@solana/web3.js";
4+
5+
export async function decompileVersionedTransactionToInstructions(
6+
connection: Connection,
7+
versionedTransaction: VersionedTransaction,
8+
) {
9+
const lookupTableAddresses = versionedTransaction.message.addressTableLookups.map((lookup) => lookup.accountKey);
10+
const addressLookupTableAccounts = await Promise.all(
11+
lookupTableAddresses.map((address) =>
12+
connection.getAddressLookupTable(address).then((lookupTable) => lookupTable.value),
13+
),
14+
);
15+
const nonNullAddressLookupTableAccounts = addressLookupTableAccounts.filter((lookupTable) => lookupTable != null);
16+
const decompileArgs: DecompileArgs = {
17+
addressLookupTableAccounts: nonNullAddressLookupTableAccounts,
18+
};
19+
return TransactionMessage.decompile(versionedTransaction.message, decompileArgs).instructions;
20+
}

‎typescript/packages/plugins/solana-magiceden/src/utils/deserializeTxResponseToInstructions.ts

+17
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
import { type Connection, VersionedTransaction } from "@solana/web3.js";
2+
import type { z } from "zod";
3+
import type { getBuyListingTransactionResponseSchema } from "../parameters";
4+
import { decompileVersionedTransactionToInstructions } from "./decompileVersionedTransactionToInstructions";
5+
6+
export async function deserializeTxResponseToInstructions(
7+
connection: Connection,
8+
txResponse: z.infer<typeof getBuyListingTransactionResponseSchema>,
9+
) {
10+
const txV0 = txResponse.v0.txSigned;
11+
if (txV0 == null) {
12+
throw new Error("No transaction in response");
13+
}
14+
const versionedTransaction = VersionedTransaction.deserialize(Buffer.from(txV0.data));
15+
const instructions = await decompileVersionedTransactionToInstructions(connection, versionedTransaction);
16+
return { versionedTransaction, instructions };
17+
}

‎typescript/packages/plugins/solana-magiceden/tsconfig.json

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
{
2+
"$schema": "https://json.schemastore.org/tsconfig",
3+
"extends": "../../../tsconfig.base.json",
4+
"include": ["src/**/*"],
5+
"exclude": ["node_modules", "dist"]
6+
}

‎typescript/packages/plugins/solana-magiceden/tsup.config.ts

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
import { defineConfig } from "tsup";
2+
import { treeShakableConfig } from "../../../tsup.config.base";
3+
4+
export default defineConfig({
5+
...treeShakableConfig,
6+
});

0 commit comments

Comments
 (0)