Function handle_command

ingest/src/connection.rs:214–341

(
    command: FtlCommand,
    sender: &mpsc::Sender<FrameCommand>,
    conn: &mut ConnectionState,
)

}

async fn handle_command(
    command: FtlCommand,
    sender: &mpsc::Sender<FrameCommand>,
    conn: &mut ConnectionState,
) {
    match command {
        FtlCommand::HMAC => {
            conn.hmac_payload = Some(generate_hmac());
            let resp = vec!["200 ".to_string(), conn.get_payload(), "\n".to_string()];
            match sender.send(FrameCommand::Send { data: resp }).await {
                Ok(_) => {}
                Err(e) => {
                    error!("Error sending to frame task (From: Handle HMAC) {:?}", e);
                }
            }
        }
        FtlCommand::Connect { data } => {
            //make sure we receive a valid channel id and stream key
            match (data.get("stream_key"), data.get("channel_id")) {
                (Some(key), Some(_channel_id)) => {
                    //decode the client hash
                    let client_hash = hex::decode(key).expect("error with hash decode");
                    let key = hmac::Key::new(hmac::HMAC_SHA512, &read_stream_key(false, Some("")));
                    //compare the two hashes to ensure they match
                    match hmac::verify(
                        &key,
                        decode(conn.get_payload().into_bytes())
                            .expect("error with payload decode")
                            .as_slice(),
                        client_hash.as_slice(),
                    ) {
                        Ok(_) => {
                            info!("Hashes match!");
                            let resp = vec!["200\n".to_string()];
                            match sender.send(FrameCommand::Send { data: resp }).await {
                                Ok(_) => {}
                                Err(e) => error!(
                                    "Error sending to frame task (From: Handle Connection) {:?}",
                                    e
                                ),
                            }
                        }
                        _ => {
                            error!("Hashes do not equal");
                        }
                    };
                }

                (None, _) => {
                    error!("No stream key attached to connect command");
                }
                (_, None) => {
                    error!("No channel id attached to connect command");
                }
            }
        }
        FtlCommand::Attribute { data } => {
            match (data.get("key"), data.get("value")) {