1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83
//! Twitter integration for [Flows.network](https://flows.network)
//!
//! # Quick Start
//!
//! To get started, let's write a very tiny flow function.
//!
//! ```rust
//! use twitter_flows::create_tweet;
//! use slack_flows::{channel_msg_received};
//!
//! #[no_mangle]
//! pub fn run() {
//! if let Some(sm) = channel_msg_received("myworkspace", "mychannel") {
//! let tweet = serde_json::json!({
//! "text": sm.text,
//! });
//! create_tweet("mytwitteruser", tweet);
//! }
//! }
//! ```
//!
//! When the Slack message is received, create a new tweet in Twitter using [create_tweet].
use http_req::{
request::{Method, Request},
uri::Uri,
};
use lazy_static::lazy_static;
use serde_json::Value;
use urlencoding::encode;
lazy_static! {
static ref TWITTER_API_PREFIX: String = String::from(
std::option_env!("TWITTER_API_PREFIX")
.unwrap_or("https://twitter-flows-extension.vercel.app/api")
);
}
extern "C" {
fn get_flows_user(p: *mut u8) -> i32;
fn set_error_log(p: *const u8, len: i32);
}
/// Create a new tweet in Twitter.
///
/// `username` is the username of your connected Twitter account.
///
/// `tweet` is a serde_json::Value::Object which is corresponding to
/// the JSON body parameters of [Twitter
/// API](https://developer.twitter.com/en/docs/twitter-api/tweets/manage-tweets/api-reference/post-tweets)
///
/// If you have not connected your Twitter account with [Flows.network platform](https://flows.network),
/// you will receive an error in the flow's building log or running log.
///
pub fn create_tweet(username: String, tweet: Value) {
unsafe {
let mut flows_user = Vec::<u8>::with_capacity(100);
let c = get_flows_user(flows_user.as_mut_ptr());
flows_user.set_len(c as usize);
let flows_user = String::from_utf8(flows_user).unwrap();
let mut writer = Vec::new();
let uri = format!(
"{}/{}/create_tweet?account={}",
TWITTER_API_PREFIX.as_str(),
flows_user,
encode(&username)
);
let uri = Uri::try_from(uri.as_str()).unwrap();
let body = serde_json::to_vec(&tweet).unwrap_or_default();
if let Ok(res) = Request::new(&uri)
.method(Method::POST)
.header("Content-Type", "application/json")
.header("Content-Length", &body.len())
.body(&body)
.send(&mut writer)
{
if !res.status_code().is_success() {
set_error_log(writer.as_ptr(), writer.len() as i32);
}
}
}
}