Initial commit

Author: andreock

.gitignore

@@ -0,0 +1,52 @@
+
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Dependency directories
+node_modules/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# Misc
+.DS_Store
+Thumbs.db
+
+
+
+# Capacitor
+ios/App/public/
+!ios/App/public/native-bridge.js
+android/app/src/main/assets/public
+!android/app/src/main/assets/public/native-bridge.js
+resources/android/icon
+resources/android/splash
+resources/ios/icon
+resources/ios/splash
+resources/windows/icon
+resources/windows/splash
+
+# Production build
+www/

README.md

@@ -0,0 +1,104 @@
+# CapibaraZero
+
+## Framework7 CLI Options
+
+Framework7 app created with following options:
+
+```
+{
+  "cwd": "/home/andreock/work/new_capibarazero",
+  "type": [
+    "pwa",
+    "capacitor"
+  ],
+  "name": "CapibaraZero",
+  "framework": "svelte",
+  "template": "tabs",
+  "bundler": "vite",
+  "cssPreProcessor": false,
+  "theming": {
+    "customColor": true,
+    "color": "#8e7559",
+    "darkMode": true,
+    "iconFonts": true
+  },
+  "customBuild": false,
+  "pkg": "io.framework7.myapp",
+  "capacitor": {
+    "platforms": [
+      "ios",
+      "android"
+    ]
+  }
+}
+```
+
+## Install Dependencies
+
+First of all we need to install dependencies, run in terminal
+```
+npm install
+```
+
+## NPM Scripts
+
+* 🔥 `start` - run development server
+* 🔧 `dev` - run development server
+* 🔧 `build` - build web app for production
+* 📱 `build-capacitor-ios` - build app and copy it to iOS capacitor project
+* 📱 `build-capacitor-android` - build app and copy it to Android capacitor project
+
+## Vite
+
+There is a [Vite](https://vitejs.dev) bundler setup. It compiles and bundles all "front-end" resources. You should work only with files located in `/src` folder. Vite config located in `vite.config.js`.
+
+## PWA
+
+This is a PWA. Don't forget to check what is inside of your `service-worker.js`. It is also recommended that you disable service worker (or enable "Update on reload") in browser dev tools during development.
+## Capacitor
+
+This project created with Capacitor support. And first thing required before start is to add capacitor platforms, run in terminal:
+
+```
+npx cap add ios && npx cap add android
+```
+
+Check out [official Capacitor documentation](https://capacitorjs.com) for more examples and usage examples.
+
+## Assets
+
+Assets (icons, splash screens) source images located in `assets-src` folder. To generate your own icons and splash screen images, you will need to replace all assets in this directory with your own images (pay attention to image size and format), and run the following command in the project directory:
+
+```
+framework7 assets
+```
+
+Or launch UI where you will be able to change icons and splash screens:
+
+```
+framework7 assets --ui
+```
+
+## Capacitor Assets
+
+Capacitor assets are located in `resources` folder which is intended to be used with `cordova-res` tool. To generate  mobile apps assets run in terminal:
+```
+npx cordova-res
+```
+
+Check out [official cordova-res documentation](https://github.com/ionic-team/cordova-res) for more usage examples.
+
+## Documentation & Resources
+
+* [Framework7 Core Documentation](https://framework7.io/docs/)
+
+
+* [Framework7 Svelte Documentation](https://framework7.io/svelte/)
+* [Framework7 Icons Reference](https://framework7.io/icons/)
+* [Community Forum](https://forum.framework7.io)
+
+## Support Framework7
+
+Love Framework7? Support project by donating or pledging on:
+- Patreon: https://patreon.com/framework7
+- OpenCollective: https://opencollective.com/framework7

api/.gitignore

@@ -0,0 +1 @@
+/target

api/Cargo.toml

@@ -0,0 +1,46 @@
+[package]
+name = "api"
+version = "0.1.0"
+edition = "2021"
+build = "src/build.rs"
+
+[dependencies]
+axum = {version = "0.8.1", features = ["ws", "multipart"]}
+tokio = { version = "1.43.0", features = ["full"] }
+serde = { version = "1.0.217", features = ["derive"]}
+serde_json = "1.0.138"
+tower-http = {version = "0.6.2", features = ["full"]}
+bluer = { version = "0.17.3", features = ["full"] }
+futures = "0.3.31"
+axum-extra = {version = "0.10.0" , features = ["typed-header"]}
+tracing = "0.1"
+tracing-subscriber = { version = "0.3", features = ["env-filter"] }
+tokio-tungstenite = "0.26.0"
+headers = "0.4"
+rand = "0.9.0"
+pnet = "0.35.0"
+netdev = "0.32.0"
+bollard = "0.18.1"
+pcap = "2.2.0"
+chrono = "0.4.39"
+libc = "0.2.169"
+zip = "2.2.2"
+dotenv = "0.15.0"
+
+[build-dependencies]
+cc = "1.2.13"
+
+[workspace.metadata.cross.target.aarch64-unknown-linux-gnu]
+# Install libssl-dev:arm64, see <https://github.com/cross-rs/cross/blob/main/docs/custom_images.md#adding-dependencies-to-existing-images>
+pre-build = [
+    "dpkg --add-architecture $CROSS_DEB_ARCH",
+    "apt-get update && apt-get --assume-yes install libdbus-1-dev:$CROSS_DEB_ARCH libpcap-dev:$CROSS_DEB_ARCH libnfc-dev:$CROSS_DEB_ARCH libusb-dev:$CROSS_DEB_ARCH libcjson-dev:$CROSS_DEB_ARCH libcjson1:$CROSS_DEB_ARCH"
+]
+
+[[bin]]
+edition = "2021"
+name = "capibarazero_api"
+path = "src/main.rs"
+
+[build.env]
+passthrough = ["LD_LIBRARY_PATH=/"]

api/src/ble/apple.rs

@@ -0,0 +1,116 @@
+use std::sync::mpsc::channel;
+use std::sync::mpsc::TryRecvError;
+use std::thread;
+use std::{process::Command, time};
+use axum::extract::connect_info::ConnectInfo;
+use axum::{
+    body::Bytes,
+    extract::ws::{Message, WebSocket, WebSocketUpgrade},
+    response::IntoResponse
+};
+use axum_extra::TypedHeader;
+
+use futures::StreamExt;
+use std::net::SocketAddr;
+use rand::prelude::*;
+
+pub fn _apple_handler(
+    ws: WebSocketUpgrade,
+    user_agent: Option<TypedHeader<headers::UserAgent>>,
+    ConnectInfo(addr): ConnectInfo<SocketAddr>,
+) -> impl IntoResponse {
+    let user_agent = if let Some(TypedHeader(user_agent)) = user_agent {
+        user_agent.to_string()
+    } else {
+        String::from("Unknown browser")
+    };
+    println!("`{user_agent}` at {addr} connected.");
+    // finalize the upgrade process by returning upgrade callback.
+    // we can customize the callback by sending additional info such as address.
+    ws.on_upgrade(move |socket| send_apple_packet(socket, addr))
+}
+
+pub async fn send_apple_packet(mut socket: WebSocket, who: SocketAddr) {
+    if socket
+        .send(Message::Ping(Bytes::from_static(&[1, 2, 3])))
+        .await
+        .is_ok()
+    {
+        println!("Pinged {who}...");
+    } else {
+        println!("Could not send ping {who}!");
+        return;
+    }
+    
+
+    let devices = vec![
+        "27", "09", "02", "1e", "2b", "2d", "2f", "01", "06", "20", "c0",
+    ];
+
+    let (tx, rx) = channel();
+
+    let (mut _sender, mut receiver) = socket.split();
+
+    let mut recv_task = tokio::spawn(async move {
+        loop {
+            let msg = receiver.next().await.expect("error").expect("error2");
+            if msg.to_text().expect("Can't parse to str") == "stop" {
+                println!("Stopping clint");
+                // cancelled = true;
+                break;
+            }
+        }
+    });
+
+    thread::spawn(move || {
+        let mut rng = rand::rng();
+        loop {
+            let mut cancelled = false;
+            for device in devices.clone() {
+                /* Generate random data for the packet */
+                let mut rnd_data1: Vec<char> = vec!['\0'; 3];
+                rnd_data1.iter_mut().for_each(|x| *x = rng.sample(rand::distr::Alphanumeric) as char);
+                let mut rnd_data2: Vec<char> = vec!['\0'; 3];
+                rnd_data2.iter_mut().for_each(|x| *x = rng.sample(rand::distr::Alphanumeric) as char);
+
+                println!("Advertising: {}", device);
+                let mut bt_process = Command::new("sh")
+                    .arg("-c")
+                    .arg(std::format!(
+                        "btmgmt add-adv -c -d 16FF4C000F05C1{}{}000010{} 1",
+                        device, rnd_data1.into_iter().collect::<String>(), rnd_data2.into_iter().collect::<String>()
+                    )).spawn().unwrap();
+                    thread::sleep(time::Duration::from_millis(2000));
+                    bt_process.wait().expect("Can't wait");
+                    match rx.try_recv() {
+                        Ok(_) | Err(TryRecvError::Disconnected) => {
+                            println!("Terminating.");
+                            cancelled = true;
+                            break;
+                        }
+                        Err(TryRecvError::Empty) => {}
+                    }
+            }
+            if cancelled {
+                println!("Killing loop");
+                let _raw_res = Command::new("sh")
+                .arg("-c")
+                .arg("pkill -9 btmgmt").spawn();
+                break;
+            }
+        }
+    });
+
+    // If any one of the tasks exit, abort the other.
+    tokio::select! {
+        rv_b = (&mut recv_task) => {
+            match rv_b {
+                Ok(_b) => println!("Rec killed"),
+                Err(b) => println!("Error receiving messages {b:?}")
+            }
+            let _ = tx.send(());
+        }
+    }
+    // send_task.
+    println!("Destroying socket");
+}