349 lines
9.3 KiB
C++
349 lines
9.3 KiB
C++
//
|
|
// wirelessly connected cloud or crowd
|
|
// over WIFI over Internet over Mountains
|
|
// across Rivers and the Universe
|
|
//
|
|
|
|
//
|
|
// tailored for "Saekki-Chigi4"
|
|
// 2026 04 13 - Seoul
|
|
//
|
|
|
|
//
|
|
// NOTES
|
|
//
|
|
|
|
// ** IDENTITY **
|
|
#define MY_SPECIES ("CHIME")
|
|
#define MY_NAME ("CHIMEE {a.k.a. chime1}")
|
|
|
|
//arduino
|
|
#include <Arduino.h>
|
|
|
|
//wifi manager
|
|
#include <WiFiManager.h>
|
|
|
|
//osc over UDP
|
|
#include <ESP8266WiFi.h>
|
|
#include <WiFiUdp.h>
|
|
#include <OSCMessage.h>
|
|
#include <OSCBundle.h>
|
|
#include <OSCData.h>
|
|
//
|
|
WiFiUDP Udp;
|
|
//
|
|
const IPAddress outIp(192,168,199,179); // server ip
|
|
const unsigned int outPort = 9999; // server port
|
|
const unsigned int localPort = 8888; // my port opened (<== expecting connection)
|
|
OSCErrorCode error;
|
|
|
|
//task
|
|
#include <TaskScheduler.h>
|
|
Scheduler runner;
|
|
|
|
//-*-*-*-*-*-*-*-*-*-*-*-*-
|
|
// servo
|
|
#define MOTOR_1A (D6)
|
|
#define MOTOR_1B (D5)
|
|
int speed = 0;
|
|
bool isactive = false;
|
|
void set_speed() {
|
|
int r = speed;
|
|
//
|
|
if (r >= 0) {
|
|
digitalWrite(MOTOR_1A, LOW);
|
|
analogWrite(MOTOR_1B, r);
|
|
} else {
|
|
digitalWrite(MOTOR_1B, LOW);
|
|
analogWrite(MOTOR_1A, r*(-1));
|
|
}
|
|
// Serial.print("set_speed:");
|
|
// Serial.println(r);
|
|
isactive = true;
|
|
}
|
|
Task set_speed_task(0, TASK_ONCE, &set_speed, &runner, false);
|
|
//
|
|
void rest() {
|
|
analogWrite(MOTOR_1A, LOW);
|
|
analogWrite(MOTOR_1B, LOW);
|
|
isactive = false;
|
|
}
|
|
Task rest_task(0, TASK_ONCE, &rest, &runner, false);
|
|
//
|
|
#define MOTOR_2A (D3)
|
|
#define MOTOR_2B (D2)
|
|
int speed2 = 0;
|
|
void set_speed2() {
|
|
int r = speed2;
|
|
//
|
|
if (r >= 0) {
|
|
digitalWrite(MOTOR_2A, LOW);
|
|
analogWrite(MOTOR_2B, r);
|
|
} else {
|
|
digitalWrite(MOTOR_2B, LOW);
|
|
analogWrite(MOTOR_2A, r*(-1));
|
|
}
|
|
// Serial.print("set_speed2:");
|
|
// Serial.println(r);
|
|
}
|
|
Task set_speed2_task(0, TASK_ONCE, &set_speed2, &runner, false);
|
|
//
|
|
void rest2() {
|
|
analogWrite(MOTOR_2A, LOW);
|
|
analogWrite(MOTOR_2B, LOW);
|
|
}
|
|
Task rest2_task(0, TASK_ONCE, &rest2, &runner, false);
|
|
//*-*-*-*-*-*-*-*-*-*-*-*-*
|
|
|
|
//*-*-*-*-*-*-*-*-*-*-*-*-*
|
|
//expressions
|
|
//riff_A
|
|
std::vector< std::vector<float> > chimeA = {
|
|
{0.4,0.133332,-0.409527,0.142857,-0.46667,0.619048,0.104762,-0.495242,-0.361908,0.466668},
|
|
//10
|
|
|
|
{0.809524,0.809524,0.819048,0.819048,0.819048,0.809524,0.7,0.695239,0.695239,0.695239,0.695239,0.438095,0.695239,0.690477,0.685715,0.447619,0.680952,0.680952,0.680952,0.680952,0.680952,0.82381,0.82381,0.666666,0.666666,0.671429,0.671429,0.814286,0.814286,0.657142,0.657142,0.657142,0.642856,0.623807,0.623807,0.623807,0.809524,0.361905,0.809524,0.361905,0.714285,0.714285,0.723809,0.761905,0.761905,0.771429,0.771429,0.771429,0.771429,0.800001}
|
|
//50
|
|
};
|
|
//
|
|
extern Task riff_A_task;
|
|
int wordA = 0;
|
|
float rateA = 900.0; // * 900 (scaling factor)
|
|
float intervalA = 2000.0; //2000 ms
|
|
void riff_A() {
|
|
//check out next letter! (==value)
|
|
speed = chimeA[wordA][riff_A_task.getRunCounter()-1] * rateA;
|
|
set_speed_task.restart();
|
|
|
|
//info
|
|
Serial.print("riff_A (i=");
|
|
Serial.print(riff_A_task.getRunCounter()-1);
|
|
Serial.print(", r=");
|
|
Serial.print(speed);
|
|
Serial.println(")");
|
|
|
|
//if we are done... schedule a 'rest_task'
|
|
if (riff_A_task.isLastIteration()) {
|
|
rest_task.restartDelayed(intervalA + 100);
|
|
}
|
|
}
|
|
Task riff_A_task(0, TASK_ONCE, &riff_A, &runner, false);
|
|
//
|
|
void riff_A_start() {
|
|
riff_A_task.setInterval(intervalA);
|
|
riff_A_task.setIterations(chimeA[wordA].size());
|
|
riff_A_task.restart();
|
|
//
|
|
Serial.print("riff_A_start with wordA #");
|
|
Serial.println(wordA);
|
|
}
|
|
Task riff_A_start_task(0, TASK_ONCE, &riff_A_start, &runner, false);
|
|
//
|
|
//riff_B
|
|
std::vector< std::vector<float> > chimeB = {
|
|
{0.4,0.133332,-0.409527,0.142857,-0.46667,0.619048,0.104762,-0.495242,-0.361908,0.466668},
|
|
//10
|
|
|
|
{0.809524,0.809524,0.819048,0.819048,0.819048,0.809524,0.7,0.695239,0.695239,0.695239,0.695239,0.438095,0.695239,0.690477,0.685715,0.447619,0.680952,0.680952,0.680952,0.680952,0.680952,0.82381,0.82381,0.666666,0.666666,0.671429,0.671429,0.814286,0.814286,0.657142,0.657142,0.657142,0.642856,0.623807,0.623807,0.623807,0.809524,0.361905,0.809524,0.361905,0.714285,0.714285,0.723809,0.761905,0.761905,0.771429,0.771429,0.771429,0.771429,0.800001}
|
|
//50
|
|
};
|
|
//
|
|
extern Task riff_B_task;
|
|
int wordB = 0;
|
|
float rateB = 900.0; // * 900 (scaling factor)
|
|
float intervalB = 2000.0; //2000 ms
|
|
void riff_B() {
|
|
//check out next letter!
|
|
speed2 = chimeB[wordB][riff_B_task.getRunCounter()-1] * rateB;
|
|
set_speed2_task.restart();
|
|
|
|
//info
|
|
Serial.print("riff_B (i=");
|
|
Serial.print(riff_B_task.getRunCounter()-1);
|
|
Serial.print(", r=");
|
|
Serial.print(speed2);
|
|
Serial.println(")");
|
|
|
|
//if we are done... schedule a 'rest_task'
|
|
if (riff_B_task.isLastIteration()) {
|
|
rest2_task.restartDelayed(intervalB + 100);
|
|
}
|
|
}
|
|
Task riff_B_task(0, TASK_ONCE, &riff_B, &runner, false);
|
|
//
|
|
void riff_B_start() {
|
|
riff_B_task.setInterval(intervalB);
|
|
riff_B_task.setIterations(chimeB[wordB].size());
|
|
riff_B_task.restart();
|
|
//
|
|
Serial.print("riff_B_start with wordB #");
|
|
Serial.println(wordB);
|
|
}
|
|
Task riff_B_start_task(0, TASK_ONCE, &riff_B_start, &runner, false);
|
|
//*-*-*-*-*-*-*-*-*-*-*-*-*
|
|
|
|
//*-*-*-*-*-*-*-*-*-*-*-*-*
|
|
// conductor for today (temporary conductor until wifi enabled.)
|
|
//
|
|
extern Task conductor_lonely_task;
|
|
float lonelytime = 5000; //ms
|
|
void conductor_lonely() {
|
|
//
|
|
static int count = 0;
|
|
if (count == chimeA.size()) count = 0;
|
|
//
|
|
if (isactive == false) { // if no more movement, then start another lonely song.
|
|
//
|
|
isactive = true;
|
|
//
|
|
lonelytime = random(3, 10) * 10000.0; //ms
|
|
//
|
|
wordA = count;
|
|
riff_A_start_task.restartDelayed(lonelytime);
|
|
wordB = count;
|
|
riff_B_start_task.restartDelayed(lonelytime);
|
|
//
|
|
Serial.print("conductor_lonely with lonelytime => ");
|
|
Serial.println(lonelytime);
|
|
Serial.print("conductor_lonely with count #");
|
|
Serial.println(count);
|
|
//
|
|
count++;
|
|
}
|
|
}
|
|
Task conductor_lonely_task(1000, TASK_FOREVER, &conductor_lonely, &runner, false);
|
|
//*-*-*-*-*-*-*-*-*-*-*-*-*
|
|
|
|
// ==[DISABLE]==
|
|
// //task #0 : blink led
|
|
// #define LED_PERIOD (11111)
|
|
// #define LED_ONTIME (1)
|
|
// #define LED_GAPTIME (222)
|
|
// #define LED_PIN 2
|
|
// extern Task blink_task;
|
|
// void blink() {
|
|
// //
|
|
// static int count = 0;
|
|
// count++;
|
|
// //
|
|
// switch (count % 4) {
|
|
// case 0:
|
|
// digitalWrite(LED_PIN, LOW); // first ON
|
|
// blink_task.delay(LED_ONTIME);
|
|
// break;
|
|
// case 1:
|
|
// digitalWrite(LED_PIN, HIGH); // first OFF
|
|
// blink_task.delay(LED_GAPTIME);
|
|
// break;
|
|
// case 2:
|
|
// digitalWrite(LED_PIN, LOW); // second ON
|
|
// blink_task.delay(LED_ONTIME);
|
|
// break;
|
|
// case 3:
|
|
// digitalWrite(LED_PIN, HIGH); // second OFF
|
|
// blink_task.delay(LED_PERIOD - 2* LED_ONTIME - LED_GAPTIME);
|
|
// break;
|
|
// }
|
|
// }
|
|
// Task blink_task(0, TASK_FOREVER, &blink, &runner, true); // -> ENABLED, at start-up.
|
|
|
|
//task #1 : osc processing
|
|
void route_note(OSCMessage& msg, int offset) {
|
|
if (msg.fullMatch("/word", offset)) {
|
|
wordA = msg.getFloat(0);
|
|
wordB = msg.getFloat(0);
|
|
riff_A_start_task.restartDelayed(100);
|
|
riff_B_start_task.restartDelayed(100);
|
|
//
|
|
Serial.print("OSC: /word : ");
|
|
Serial.print(wordA);
|
|
Serial.print(", ");
|
|
Serial.println(wordB);
|
|
}
|
|
}
|
|
extern Task osc_task;
|
|
void osc()
|
|
{
|
|
//osc
|
|
OSCMessage msg;
|
|
int size = Udp.parsePacket();
|
|
if (size > 0) {
|
|
while (size--) {
|
|
msg.fill(Udp.read());
|
|
}
|
|
if(!msg.hasError()) {
|
|
// on '/yellow'
|
|
msg.route("/yellow", route_note);
|
|
Serial.println("OSC: /yellow");
|
|
}
|
|
}
|
|
}
|
|
Task osc_task(0, TASK_FOREVER, &osc, &runner, true); // -> ENABLED, at start-up.
|
|
|
|
//
|
|
void setup() {
|
|
|
|
//led
|
|
// pinMode(LED_PIN, OUTPUT);
|
|
|
|
//pwm freq.
|
|
analogWriteFreq(40000);
|
|
|
|
//serial
|
|
Serial.begin(115200);
|
|
delay(100);
|
|
|
|
//info
|
|
Serial.println();
|
|
Serial.println();
|
|
Serial.println("\"hi, i m your friend.\"");
|
|
Serial.println("-");
|
|
Serial.println("- my species: \"" + String(MY_SPECIES) + "\"");
|
|
Serial.println("- call me ==> \"" + String(MY_NAME) + "\"");
|
|
Serial.println("- mac address: " + WiFi.macAddress());
|
|
Serial.println("-");
|
|
|
|
// //wifi-manager
|
|
// Serial.println("- calling.. wifimanager");
|
|
// WiFiManager wm;
|
|
// if (!wm.autoConnect()) ESP.restart();
|
|
// Serial.println("- i m connected!");
|
|
|
|
//open up udp connection
|
|
Serial.println("- IP address: ");
|
|
Serial.println(WiFi.localIP());
|
|
Serial.println("- Starting UDP");
|
|
Udp.begin(localPort);
|
|
Serial.print("- Local port: ");
|
|
Serial.println(Udp.localPort());
|
|
|
|
//all done.
|
|
Serial.println("-");
|
|
Serial.println("\".-.-.-. :)\"");
|
|
Serial.println();
|
|
|
|
//random seed
|
|
randomSeed(analogRead(0));
|
|
|
|
//tasks
|
|
rest_task.restartDelayed(500);
|
|
rest2_task.restartDelayed(500);
|
|
|
|
wordA = 0;
|
|
riff_A_start_task.restartDelayed(1000);
|
|
wordB = 0;
|
|
riff_B_start_task.restartDelayed(1000);
|
|
|
|
conductor_lonely_task.restartDelayed(5000);
|
|
//
|
|
// for (int idx = 0; idx < chimeA.size(); idx++) Serial.println(chimeA[idx].size());
|
|
// for (int idx = 0; idx < chimeB.size(); idx++) Serial.println(chimeB[idx].size());
|
|
//
|
|
}
|
|
|
|
void loop() {
|
|
//
|
|
runner.execute();
|
|
//
|
|
}
|