cyphercast

        let now = Clock::get()?.unix_timestamp;        require!(            now < stream                .start_time                .checked_add(stream.lock_offset_secs)                .ok_or(CypherCastError::Overflow)?,            CypherCastError::StreamLocked        );         // Transfer SPL tokens from viewer's ATA to vault ATA for prediction stake        let cpi_ctx = CpiContext::new(            ctx.accounts.token_program.to_account_info(),            Transfer {                from: ctx.accounts.viewer_token_account.to_account_info(),                to: ctx.accounts.vault_token_account.to_account_info(),                authority: ctx.accounts.viewer.to_account_info(),            },        );        token::transfer(cpi_ctx, stake_amount)?;         vault.total_deposited = vault            .total_deposited            .checked_add(stake_amount)            .ok_or(CypherCastError::Overflow)?;

1. Line 121 let now = Clock::get()?.unix_timestamp;: Reads on-chain time from the Clock sysvar.
2. Line 122 require!(: An explicit validation that aborts the instruction with an error.
3. Line 125 .checked_add(stream.lock_offset_secs): Uses checked arithmetic so overflow fails instead of wrapping.
4. Line 130 // Transfer SPL tokens from viewer's ATA to vault ATA for prediction stake: Touches staking state: the amount locked and when it was locked.
5. Line 131 let cpi_ctx = CpiContext::new(: Makes a cross-program invocation into another program.
6. Line 139 token::transfer(cpi_ctx, stake_amount)?;: An SPL token transfer through the Token Program.

      log(`   Participant PDA: ${participantPda.toString()}`, 'cyan');            return { participantPda, signature };          } catch (error) {      log(`\n❌ Failed to join stream: ${error.message}`, 'red');      if (error.logs) {        log('Program logs:', 'yellow');        error.logs.forEach(l => log(`   ${l}`, 'reset'));      }      throw error;    }  }   async submitPrediction(streamPda, choice, stake) {    try {      log('\n🎯 Submitting Prediction...', 'yellow');      log('─'.repeat(50), 'cyan');            const streamPubkey = new PublicKey(streamPda);      const [predictionPda, bump] = await this.derivePredictionPDA(streamPubkey, this.keypair.publicKey);            // Convert choice to u8 (0-255)      const choiceU8 = typeof choice === 'string' ? parseInt(choice) || 0 : choice;

1. Line 255 async submitPrediction(streamPda, choice, stake) {: Touches staking state: the amount locked and when it was locked.
2. Line 261 const [predictionPda, bump] = await this.derivePredictionPDA(streamPubkey, this.keypair.pu: Uses the bump seed, the extra byte that pushes the derived address off the ed25519 curve.