Deploying Your Custom Solana Protocol

This guide provides step-by-step instructions on how to deploy your custom Solana protocol. By following these steps, you can successfully deploy your custom Solana protocol across multiple chains. If you encounter issues, refer to the How to Debug Sent Messages guide or reach out to us through our contact form.

Prerequisites

Ensure you have the latest versions installed.

Before proceeding, ensure you are familiar with writing Solana programs in Rust.

In this guide we'll be using anchor as the framework of choice, but native programs will work as well. You can follow the anchor installation guide if it's your first time using it.

Before proceeding make sure you have setup your environment first, as shown below.

agave-install init 2.1.0 # solana
avm use 0.31.0 # anchor

Contract Dependencies

To streamline development, start by adding the UIP Solana SDK dependency to the configuration file.

If you are not using Anchor, you don’t need to enable the anchor-lang feature.

programs/*/Cargo.toml

uip-solana-sdk = { version = "0.1", features = ["anchor-lang"] }

Then, if you are developing an EVM to non-EVM protocol, you will likely need to use a library for EVM ABI encoding, we recommend using alloy:

alloy-sol-types = "0.7"

Sending a message

To send a message you need to perform a CPI to the endpoint.

First, you need to declare the following accounts:

use uip_solana_sdk::UipEndpoint;

#[derive(Accounts)]
pub struct SendMessage<'info> {
    #[account(mut)]
    sender: Signer<'info>,
    /// CHECK: checked in the CPI
    endpoint_config: AccountInfo<'info>,
    /// CHECK: checked in the CPI
    #[account(mut)]
    uts_connector: AccountInfo<'info>,
    /// CHECK: checked in CPI
    #[account(seeds = [b"UIP_SIGNER"], bump)]
    program_signer: AccountInfo<'info>,
    system_program: Program<'info, System>,
    uip_program: Program<'info, UipEndpoint>,
}

sender is the payer for the operation. program_signer is a special PDA used to identify your program. And uts_connector can be retrieved using the fetchUtsConnector function from the TypeScript helpers.

Now, in the instruction, you can perform the Propose CPI:

use uip_solana_sdk::{chains::*, Commitment, UipEndpoint};

UipEndpoint::propose()
    .payer(ctx.accounts.sender.to_account_info())
    .endpoint_config(ctx.accounts.endpoint_config.to_account_info())
    .uts_connector(ctx.accounts.uts_connector.to_account_info())
    .program_signer(ctx.accounts.program_signer.to_account_info())
    .system_program(ctx.accounts.system_program.to_account_info())
    .program_signer_bump(ctx.bumps.program_signer)
    .sender(&crate::ID)
    .total_fee(uip_fee)
    .dest_chain_id(dest_chain_id)
    .dest_addr(&dest_addr)
    .payload(&payload)
    .custom_gas_limit(custom_gas_limit)
    .proposal_commitment(Commitment::Confirmed)
    .call()?;

Notice the following parameters:

• total_fee - it’s the fee paid for the message, usually calculated using the TypeScript UIP SDK

• dest_chain_id - chain ID of the destination network

• selector - in most situations it should be omitted

• dest_addr - address of the destination contract. If you’re sending to an EVM chain, make sure you left pad it so it’s 32 bytes

• payload - the payload, carries any data you want to send

• proposal_commitment - whether transmitters should wait for your proposal transaction to be finalized or confirmed. Skipping the finalization will reduce the transmission time by about 15 seconds, but could theoretically pose a risk if the Solana blockchain is compromised

• custom_gas_limit - used on the EVM destination to limit gas usage, must not be zero

Receiving a message

First, import some helper methods.

use uip_solana_sdk::{chains::*, parse_uip_message, route_instruction, MessageDataRef};

When a message is received, the endpoint will invoke a special instruction on your contract with a specific discriminator: uip_solana_sdk::EXECUTE_DISCRIMINATOR. When using the Anchor framework, it can be declared like so:

#[instruction(discriminator = uip_solana_sdk::EXECUTE_DISCRIMINATOR)]
pub fn execute<'info>(ctx: Context<'_, '_, 'info, 'info, Execute>) -> Result<()> {
    // your code
}

If you are not using Anchor, make sure that the first 8 bytes of instruction data match uip_solana_sdk::EXECUTE_DISCRIMINATOR.

Now, the Execute instruction should take no arguments and require a single account, the UIP message:

#[derive(Accounts)]
pub struct Execute<'info> {
    /// CHECK: It's checked in `parse_uip_message`.
    uip_msg: AccountInfo<'info>,
}

The payer and the accounts that are specific to your protocol (specified in Solana network integration | Extension registration) will come after uip_msg. If you only need a single set of accounts for all possible payloads, you can specify these accounts in the same structure after uip_msg. Otherwise, they will be put ctx.remaining_accounts for further routing.

In the function body, you should parse the incoming message:

let uip_msg_data = ctx.accounts.uip_msg.try_borrow_data()?;
let MessageDataRef {
    payload,
    sender_addr,
    src_chain_id,
    msg_hash,
    ..
} = parse_uip_message(&ctx.accounts.uip_msg, &uip_msg_data, &crate::ID)?;

First, you should validate that src_chain_id and sender_addr match one of the smart contracts that your protocol supports.

Then, decode the payload for further processing.

If you are using Anchor and expect different accounts for different types of messages, you can use the helper route_instruction function that can make it appear as if you are routing a real instruction, for example:

if some_condition {
    let ix_data = MyIxData {
        //
    };
    let input = MyIxInput {
        //
    };

    route_instruction(
        &crate::ID,
        my_ix,
        ctx.remaining_accounts,
        ix_data,
        input,
    )?;
} else {
  // route another instruction
}

Here, my_ix is defined as any other instruction, but is not made public. The first account must be payer, which is the UIP executor. The following accounts must be the custom accounts that you need. Don’t forget to perform all the required checks for these accounts.

#[derive(Accounts)]
#[instruction(ix_data: MyIxData)]
struct MyIx<'info> {
    #[account(mut)]
    payer: Signer<'info>,
    // other accounts
}

fn my_ix(ctx: Context<MyIx>, message: MyIxInput) -> Result<()> {
    // your implementation
}

Lastly, for the Execute instruction to be connected to the UIP network, you need to register your protocol extension: Solana network integration | Extension registration.

Extension registration

Solana is different to other networks in that apart from function parameters it needs accounts to be specified. In order for the executor to know what accounts need to be passed, we utilize something called extensions, compiled to WASM and stored on IPFS. Basically, it’s a separate library that describes your Execute instruction interface.

To implement it, initialize a new library and specify the following in Cargo.toml:

[lib]
crate-type = ["cdylib"]

[dependencies]
solana-program = ">=2.0,<2.2"
uip-solana-sdk = "0.1"

Then, you need to write a function called get_api_version that returns the version of the extension API that your extension supports. Right now, 0 is the only supported version so leave it at that.

Then, you need to write the get_instruction_info function with a specific signature, that takes MessageData and writes back the required accounts, compute units, and heap frame back into InstructionInfo. If your program needs more heap than the default, you can request heap frame (it must be a multiple of 1024 less than 256 KiB), otherwise leave it at 0.

Here’s an example of an extension:

use solana_program::{instruction::AccountMeta, pubkey::Pubkey, system_program};
use uip_solana_sdk::{deserialize_message_data, MessageDataRef};

#[repr(C)]
pub struct InstructionInfo {
    pub compute_units: u32,
    pub heap_frame: u32,
    pub accounts_len: u32,
    pub accounts: [AccountMeta; 32],
}

#[no_mangle]
pub extern "C" fn get_api_version() -> u32 {
    0
}

#[no_mangle]
pub unsafe extern "C" fn get_instruction_info(
    msg_data_ptr: *const u8,
    msg_data_len: usize,
    result: &mut InstructionInfo,
) {
    let msg_data = core::slice::from_raw_parts(msg_data_ptr, msg_data_len);
    let MessageDataRef { payload, msg_hash, .. } = deserialize_message_data(msg_data).unwrap();

    let (example_pda, _) =
        Pubkey::find_program_address(&[b"EXAMPLE"], &my_protocol::ID.to_bytes().into());
    result.accounts[0] = AccountMeta::new(example_pda, false);
    result.accounts[1] = AccountMeta::new_readonly(system_program::ID, false);
    result.accounts_len = 2;
    result.compute_units = 150_000;
    result.heap_frame = 0;
}

After that, you need to compile the extension to the WASI target:

cargo build --target wasm32-wasip1 --release -p example-extension
wasm-opt -O4 target/wasm32-wasip1/release/example_extension.wasm -o target/wasm32-wasip1/release/example_extension-optimized.wasm

Then upload target/wasm32-wasip1/release/example_extension-optimized.wasm to IPFS, using a service such as Pinata (it’s free).

After that, record the CID of the uploaded file. You need to convert it to 36 bytes, it can be done using the multiformats package:

import { CID } from "multiformats";

Array.from(CID.parse(ipfsCid).toV1().bytes) 

Your program needs to have an instruction that registers the extension using a CPI call. We recommend gating it with access control, so that only an admin or multisig can call it. You can run the instruction during initialization or upgrade of your program.

use uip_solana_sdk::UipEndpoint;

UipEndpoint::register_extension()
    .payer(ctx.accounts.payer.to_account_info())
    .extension(ctx.accounts.extension.to_account_info())
    .program_signer(ctx.accounts.program_signer.to_account_info())
    .system_program(ctx.accounts.system_program.to_account_info())
    .program_signer_bump(ctx.bumps.program_signer)
    .program_id(&crate::ID)
    .ipfs_cid(ipfs_cid)
    .call()?;

uip_signer needs to be a special PDA with the following seeds: [b"UIP_SIGNER"]. The required extension can be found using the following function:

const findExtension = (program: PublicKey) =>
  PublicKey.findProgramAddressSync([
    Buffer.from("EXTENSION"),
    program.toBuffer(),
  ], UIP_PROGRAM.programId)[0];

After performing RegisterExtension, your contract can now receive UIP messages! To implement the instruction, follow Solana network integration | Receiving a message.

Client-side scripts and testing

In order to start testing your contract and sending scripts, you need to import the IDL (Solana analogue of ABI).

For a default Anchor configuration, you can put this file in target/idl:

36KB

uip_endpoint.json

And this file in target/types:

36KB

uip_endpoint.ts

Then you can use the endpoint methods in your TypeScript files:

const UIP_PROGRAM: Program<UipEndpoint> = anchor.workspace.UipEndpoint;

Testing your contract

In order to test execution of your messages, you can mimic the cross-chain message execution on localnet. For this, you can use a mock UIP config with a predefined signer configuration:

654B

uip_config.json

You can put it in tests/accounts/uip_config.json. Then, you can configure Anchor to load the mock account and the other accounts necessary for UIP endpoint execution. Add this to Anchor.toml:

[test.validator]
url = "https://api.devnet.solana.com"
[[test.validator.clone]]
# UIP program
address = "uipby67GWuDDt1jZTWFdXNrsSu83kcxt9r5CLPTKGhX"
[[test.validator.clone]]
# UTS config
address = "CTspuKSu7eRXzKqtYzR83H5VCZMWVRC4uRLfrA5Cy8WX"
[[test.validator.clone]]
# UTS connector
address = "vAukQz25gyuAHbdzEQS9GxMVZipVFu18MUoayKpETJz"
[[test.validator.account]]
address = "CMFjqmzBd59mHnHZgGz9c1ppZPN8VFnWZ8UtxPVUEJLq"
filename = "tests/accounts/uip_config.json"

Then you can use the following UIP endpoint helpers:

6KB

utils.ts

9KB

endpoint.ts

Here’s an example of sending a message and intercepting the UIP proposal event.

const eventPromise: Promise<void> = new Promise((resolve, reject) => {
  UIP_PROGRAM.addEventListener(
    "messageProposed",
    (event) => {
      try {
        selector = event.selector;
        payload = event.payload;
        resolve();
      } catch (error) {
        reject(error);
      }
    },
  );

  setTimeout(() => {
    reject(new Error("Event did not fire within timeout"));
  }, 15000);
});

// send message

const txId = bs58.decode(transactionSignature);
srcOpTxId[0] = Array.from(txId.subarray(0, 32));
srcOpTxId[1] = Array.from(txId.subarray(32));

await eventPromise;

And here’s an example of executing a message.

const transmitterParams = {
  proposalCommitment: { confirmed: {} },
  customGasLimit: new BN(2),
};
const transmitterParamsEncoded = encodeTransmitterParams(transmitterParams);

const signer = new Wallet(
  "0x74e3ffad2b87174dc1d806edf1a01e3b017cf1be05d1894d329826f10fa1d72f",
);

const msgData = {
  initialProposal: {
    senderAddr,
    destAddr,
    ccmFee,
    payload,
    reserved: Buffer.from([]),
    transmitterParams: transmitterParamsEncoded,
    selector,
  },
  srcChainData: {
    srcBlockNumber,
    srcChainId,
    srcOpTxId,
  },
};
 
const signatures = [signMsg(signer, msgData)];

const input = {
  executor,
  msgData,
  signatures,
  accounts,
  spendingLimit: new BN(100_000),
};

await executeFull(input);

Sending messages that don’t fit in a single Solana transaction

We have developed a utility program to allow loading data in chunks to later be used to invoke a Solana instruction. It allows passing up to 10KB of data to an instruction, bypassing the normal limit of around 1KB per instruction.

It will be automatically used by executors when a large message is passed to Solana from another chain. However, if you want to send a large transaction from Solana, you can also use the Chunk Loader program with the following IDL and helpers:

3KB

chunk_loader.ts

3KB

chunk_loader.json

2KB

chunkLoader.ts

In order to pass large data to your function, you need to manually encode the function selector and arguments to a buffer, and then pass it by chunks to the Chunk Loader program:

const chunkId = randomInt(1 << 19);

const doLoadChunk = async (
  index: number,
  len?: number,
) => {
  await loadChunk({
    owner: payer,
    chunk: {
      data: data.subarray(
        index * MAX_CHUNK_LEN,
        len ? index * MAX_CHUNK_LEN + len : undefined,
      ),
      index,
    },
    chunkId,
  });
};

const num_extends = Math.floor(data.length / MAX_CHUNK_LEN);

const promises: Array<Promise<void>> = [];
for (let i = 0; i < num_extends; i++) {
  promises.push(doLoadChunk(i, MAX_CHUNK_LEN));
}
promises.push(doLoadChunk(num_extends));
await Promise.all(promises);

return await passToCpi({
  owner: payer,
  program: YOUR_PROGRAM.programId,
  chunkId,
  accounts: [
    { pubkey: sender.publicKey, isSigner: true, isWritable: true },
    { pubkey: ENDPOINT_CONFIG, isSigner: false, isWritable: false },
    { pubkey: await fetchUtsConnector(), isSigner: false, isWritable: true },
    {
      pubkey: PublicKey.findProgramAddressSync(
        [Buffer.from("UIP_SIGNER")],
        YOUR_PROGRAM.programId,
      )[0],
      isSigner: false,
      isWritable: false,
    },
    {
      pubkey: SystemProgram.programId,
      isSigner: false,
      isWritable: false,
    },
    {
      pubkey: UIP_PROGRAM.programId,
      isSigner: false,
     isWritable: false,
    },
  ],
  signers: [sender],
});