doohoyi/forest-all-around
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

updated 'p'

Browse source 
more straightforward que generation.
This commit is contained in:
Dooho Yi 2024-10-30 20:57:01 +09:00
parent 410b42c303
commit 0e0157db06
1 changed files with 263 additions and 258 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

521
p/src/main.cpp
View file

@ -90,8 +90,10 @@ Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);
// q list // q list
std::vector<Note> qlist; std::vector<Note> qlist;
void init_qlist() { void init_qlist() {
qlist.push_back(Note(10000, 1, 0, 1, 0, 0, 0, 0, 0)); qlist.push_back(Note(1444, 12, 0, 1, 0, 0, 0, 0, 0));
qlist.push_back(Note(10000, 1, 0, 0, 0, 0, 0, 0, 0)); qlist.push_back(Note(1444, 12, 0, 0, 0, 0, 0, 0, 0));
qlist.push_back(Note(1444, 14, 0, 1, 0, 0, 0, 0, 0));
qlist.push_back(Note(1444, 14, 0, 0, 0, 0, 0, 0, 0));
} }
//buttons //buttons
@ -109,9 +111,9 @@ String screen_cmd = ":Q: ----- --- --- -";
extern Task screen_req_notify_task; extern Task screen_req_notify_task;
bool req_notify = false; bool req_notify = false;
void screen_req_notify() { void screen_req_notify() {
if (screen_req_notify_task.isFirstIteration()) req_notify = true; if (screen_req_notify_task.isFirstIteration()) req_notify = true;
else if (screen_req_notify_task.isLastIteration()) req_notify = false; else if (screen_req_notify_task.isLastIteration()) req_notify = false;
else req_notify = !req_notify; else req_notify = !req_notify;
} }
Task screen_req_notify_task(500, 8, &screen_req_notify, &runner, false); Task screen_req_notify_task(500, 8, &screen_req_notify, &runner, false);
@ -119,177 +121,180 @@ Task screen_req_notify_task(500, 8, &screen_req_notify, &runner, false);
extern Task screen_task; extern Task screen_task;
void screen() { void screen() {
//
if (screen_task.isFirstIteration()) {
init_qlist();
}
// button job!
static int btn_vol_up = 0;
static int btn_vol_down = 0;
static int btn_mute = 0;
static int btn_previous = 0;
static int btn_pause = 0;
static int btn_next = 0;
//
int a;
static int qselect = 0;
bool nowsend = false;
//
a = digitalRead(pin_vol_up);
if(btn_vol_up != a) {
btn_vol_up = a;
if(a == 0) {
// 'vol_up' button pressed.
qselect = qselect + 1;
if (qselect > (qlist.size() - 1)) qselect = 0;
}
}
//
a = digitalRead(pin_vol_down);
if(btn_vol_down != a) {
btn_vol_down = a;
if(a == 0) {
// 'vol_down' button pressed.
qselect = qselect - 1;
if (qselect < 0) qselect = (qlist.size() - 1);
}
}
//
a = digitalRead(pin_mute);
if(btn_mute != a) {
btn_mute = a;
if(a == 0) {
// 'mute' button pressed.
nowsend = true;
}
}
//
a = digitalRead(pin_previous);
if(btn_previous != a) {
btn_previous = a;
if(a == 0) {
// 'previous' button pressed.
qselect = qselect - 1;
if (qselect < 0) qselect = (qlist.size() - 1);
}
}
//
a = digitalRead(pin_pause);
if(btn_pause != a) {
btn_pause = a;
if(a == 0) {
// 'pause' button pressed.
nowsend = true;
}
}
//
a = digitalRead(pin_next);
if(btn_next != a) {
btn_next = a;
if(a == 0) {
// 'next' button pressed.
qselect = qselect + 1;
if (qselect > (qlist.size() - 1)) qselect = 0;
}
}
if (nowsend == true) {
nowsend = false;
// create a NOTE req. and send it out.
// //
MONITORING_SERIAL.print("# posting a req.# ==> "); if (screen_task.isFirstIteration()) {
MONITORING_SERIAL.println(qlist[qselect].to_string()); init_qlist();
}
// button job!
static int btn_vol_up = 0;
static int btn_vol_down = 0;
static int btn_mute = 0;
static int btn_previous = 0;
static int btn_pause = 0;
static int btn_next = 0;
// //
uint8_t frm_size = sizeof(Note) + 2; int a;
uint8_t frm[frm_size]; static int qselect = 0;
frm[0] = '['; bool nowsend = false;
memcpy(frm + 1, (uint8_t *) &qlist[qselect], sizeof(Note));
frm[frm_size - 1] = ']';
// //
// strange but following didn't work as expected. (instead, i have to send one-by-one.) a = digitalRead(pin_vol_up);
// esp_now_send(NULL, frm, frm_size); // to all peers in the list. if(btn_vol_up != a) {
btn_vol_up = a;
if(a == 0) {
// 'vol_up' button pressed.
// so, forget about peer list -> just pick a broadcast peer to be sent. qselect = qselect + 1;
uint8_t broadcastmac[6] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF}; if (qselect > (qlist.size() - 1)) qselect = 0;
esp_now_send(broadcastmac, frm, frm_size); }
}
//
a = digitalRead(pin_vol_down);
if(btn_vol_down != a) {
btn_vol_down = a;
if(a == 0) {
// 'vol_down' button pressed.
qselect = qselect - 1;
if (qselect < 0) qselect = (qlist.size() - 1);
}
}
//
a = digitalRead(pin_mute);
if(btn_mute != a) {
btn_mute = a;
if(a == 0) {
// 'mute' button pressed.
nowsend = true;
}
}
//
a = digitalRead(pin_previous);
if(btn_previous != a) {
btn_previous = a;
if(a == 0) {
// 'previous' button pressed.
qselect = qselect - 1;
if (qselect < 0) qselect = (qlist.size() - 1);
}
}
//
a = digitalRead(pin_pause);
if(btn_pause != a) {
btn_pause = a;
if(a == 0) {
// 'pause' button pressed.
nowsend = true;
}
}
//
a = digitalRead(pin_next);
if(btn_next != a) {
btn_next = a;
if(a == 0) {
// 'next' button pressed.
qselect = qselect + 1;
if (qselect > (qlist.size() - 1)) qselect = 0;
}
}
if (nowsend == true) {
nowsend = false;
// create a NOTE req. and send it out.
//
MONITORING_SERIAL.print("# posting a req.# ==> ");
MONITORING_SERIAL.println(qlist[qselect].to_string());
//
uint8_t frm_size = sizeof(Note) + 2;
uint8_t frm[frm_size];
frm[0] = '[';
memcpy(frm + 1, (uint8_t *) &qlist[qselect], sizeof(Note));
frm[frm_size - 1] = ']';
//
// strange but following didn't work as expected. (instead, i have to send one-by-one.)
// esp_now_send(NULL, frm, frm_size); // to all peers in the list.
// so, forget about peer list -> just pick a broadcast peer to be sent.
uint8_t broadcastmac[6] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
esp_now_send(broadcastmac, frm, frm_size);
//+ fancy stuff //+ fancy stuff
screen_req_notify_task.restart(); screen_req_notify_task.restart();
//+ automatically increase 'song_request' // //+ automatically increase 'song_request'
qselect = qselect + 1; // qselect = qselect + 1;
if (qselect > (qlist.size() - 1)) qselect = 0; // if (qselect > (qlist.size() - 1)) qselect = 0;
} }
//clear screen + a //clear screen + a
int line_step = 12; int line_step = 12;
int line = 0; int line = 0;
display.clearDisplay(); display.clearDisplay();
display.setTextColor(SSD1306_WHITE); display.setTextColor(SSD1306_WHITE);
display.setTextSize(1); display.setTextSize(1);
//button status (DEBUG) //button status (DEBUG)
// int b = digitalRead(pin_vol_up); // int b = digitalRead(pin_vol_up);
// b = b*10 + digitalRead(pin_vol_down); // b = b*10 + digitalRead(pin_vol_down);
// b = b*10 + digitalRead(pin_mute); // b = b*10 + digitalRead(pin_mute);
// b = b*10 + digitalRead(pin_previous); // b = b*10 + digitalRead(pin_previous);
// b = b*10 + digitalRead(pin_pause); // b = b*10 + digitalRead(pin_pause);
// b = b*10 + digitalRead(pin_next); // b = b*10 + digitalRead(pin_next);
//line1 - mode line (playing / stopped) + notify mark //line1 - mode line (playing / stopped) + notify mark
display.setCursor(0, line); display.setCursor(0, line);
display.printf("= transmitting ))) =="); display.printf("= transmitting ))) ==");
line += line_step; line += line_step;
//line3 - msg. ready to be sent now. //line3 - msg. ready to be sent now.
display.setCursor(0, line); display.setCursor(0, line);
display.printf(":Q: %05d %03d %03d %01d", (int)qlist[qselect].id, (int)qlist[qselect].pitch, (int)qlist[qselect].velocity, (int)qlist[qselect].onoff); display.setTextSize(2);
line += line_step; display.printf(":Q: %05d %03d %03d %01d", (int)qlist[qselect].id, (int)qlist[qselect].pitch, (int)qlist[qselect].velocity, (int)qlist[qselect].onoff);
line += line_step;
//line4 - big file name display // //line4 - big file name display
display.setCursor(0, line); // display.setCursor(0, line);
display.setTextSize(2); // display.setTextSize(2);
// // //
char filename[14] = "/NNN.mp3 >"; // char filename[14] = "/NNN.mp3 >";
int note = qlist[qselect].pitch; // int note = qlist[qselect].pitch;
int nnn = (note % 1000); // 0~999 // int nnn = (note % 1000); // 0~999
int nn = (note % 100); // 0~99 // int nn = (note % 100); // 0~99
filename[1] = '0' + (nnn / 100); // N__.MP3 // filename[1] = '0' + (nnn / 100); // N__.MP3
filename[2] = '0' + (nn / 10); // _N_.MP3 // filename[2] = '0' + (nn / 10); // _N_.MP3
filename[3] = '0' + (nn % 10); // __N.MP3 // filename[3] = '0' + (nn % 10); // __N.MP3
// // //
if (qlist[qselect].onoff == 0) { // if (qlist[qselect].onoff == 0) {
filename[9] = 'x'; // filename[9] = 'x';
} // }
display.println(filename); // display.println(filename);
line += line_step; // line += line_step;
display.setTextSize(1); // display.setTextSize(1);
line += 8; // line += 8;
// //alternative line3+4 - full msg. dump (DEBUG/MONITORING) // //alternative line3+4 - full msg. dump (DEBUG/MONITORING)
// display.setCursor(0, line); // display.setCursor(0, line);
// display.println(":Q: " + qlist[qselect].to_string()); // display.println(":Q: " + qlist[qselect].to_string());
// line += line_step; line += line_step;
line += line_step;
//line5 - song req. tx. notify. (GEN_NOTE_REQ) //line5 - song req. tx. notify. (GEN_NOTE_REQ)
display.setCursor(0, line); display.setCursor(0, line);
if (req_notify) { display.setTextSize(1);
display.setCursor(25, line); if (req_notify) {
display.println("~~ d[+=+]b ~~ >>>"); display.setCursor(25, line);
} display.println("~~ d[+=+]b ~~ >>>");
line += line_step; }
line += line_step;
// //
display.display(); display.display();
// //
} }
Task screen_task(SCREEN_PERIOD, TASK_FOREVER, &screen, &runner, true); Task screen_task(SCREEN_PERIOD, TASK_FOREVER, &screen, &runner, true);
//*-*-*-*-*-*-*-*-*-*-*-*-* //*-*-*-*-*-*-*-*-*-*-*-*-*
@ -297,129 +302,129 @@ Task screen_task(SCREEN_PERIOD, TASK_FOREVER, &screen, &runner, true);
// on 'receive' // on 'receive'
void onDataReceive(const uint8_t * mac, const uint8_t *incomingData, int32_t len) { void onDataReceive(const uint8_t * mac, const uint8_t *incomingData, int32_t len) {
// open => identify => use. // open => identify => use.
if (incomingData[0] == '{' && incomingData[len - 1] == '}' && len == (sizeof(Hello) + 2)) { if (incomingData[0] == '{' && incomingData[len - 1] == '}' && len == (sizeof(Hello) + 2)) {
Hello hello(""); Hello hello("");
memcpy((uint8_t *) &hello, incomingData + 1, sizeof(Hello)); memcpy((uint8_t *) &hello, incomingData + 1, sizeof(Hello));
// //
MONITORING_SERIAL.println(hello.to_string()); MONITORING_SERIAL.println(hello.to_string());
// //
} }
// open => identify => use. // open => identify => use.
if (incomingData[0] == '[' && incomingData[len - 1] == ']' && len == (sizeof(Note) + 2)) { if (incomingData[0] == '[' && incomingData[len - 1] == ']' && len == (sizeof(Note) + 2)) {
Note note; Note note;
memcpy((uint8_t *) &note, incomingData + 1, sizeof(Note)); memcpy((uint8_t *) &note, incomingData + 1, sizeof(Note));
// //
MONITORING_SERIAL.println(note.to_string()); MONITORING_SERIAL.println(note.to_string());
// //
} }
} }
// on 'sent' // on 'sent'
void onDataSent(const uint8_t *mac_addr, esp_now_send_status_t sendStatus) { void onDataSent(const uint8_t *mac_addr, esp_now_send_status_t sendStatus) {
if (sendStatus != 0) MONITORING_SERIAL.println("Delivery failed!"); if (sendStatus != 0) MONITORING_SERIAL.println("Delivery failed!");
} }
void lcd_text(String str) { void lcd_text(String str) {
display.clearDisplay(); display.clearDisplay();
display.setTextColor(SSD1306_WHITE); display.setTextColor(SSD1306_WHITE);
display.setTextSize(1); display.setTextSize(1);
display.setCursor(0, 0); display.setCursor(0, 0);
display.println(str.c_str()); display.println(str.c_str());
display.display(); display.display();
} }
// //
void setup() { void setup() {
//buttons //buttons
pinMode(pin_vol_up, INPUT_PULLUP); pinMode(pin_vol_up, INPUT_PULLUP);
pinMode(pin_vol_down, INPUT_PULLUP); pinMode(pin_vol_down, INPUT_PULLUP);
pinMode(pin_mute, INPUT_PULLUP); pinMode(pin_mute, INPUT_PULLUP);
pinMode(pin_previous, INPUT_PULLUP); pinMode(pin_previous, INPUT_PULLUP);
pinMode(pin_pause, INPUT_PULLUP); pinMode(pin_pause, INPUT_PULLUP);
pinMode(pin_next, INPUT_PULLUP); pinMode(pin_next, INPUT_PULLUP);
//serial //serial
Serial.begin(115200); Serial.begin(115200);
delay(100); delay(100);
//screen //screen
Wire.begin(MAKEPYTHON_ESP32_SDA, MAKEPYTHON_ESP32_SCL); Wire.begin(MAKEPYTHON_ESP32_SDA, MAKEPYTHON_ESP32_SCL);
// SSD1306_SWITCHCAPVCC = generate display voltage from 3.3V internally // SSD1306_SWITCHCAPVCC = generate display voltage from 3.3V internally
if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) { // Address 0x3C for 128x32 if (!display.begin(SSD1306_SWITCHCAPVCC, 0x3C)) { // Address 0x3C for 128x32
Serial.println(F("SSD1306 allocation failed")); Serial.println(F("SSD1306 allocation failed"));
for (;;) for (;;)
; // Don't proceed, loop forever ; // Don't proceed, loop forever
} }
display.clearDisplay(); display.clearDisplay();
//info //info
Serial.println(); Serial.println();
Serial.println(); Serial.println();
Serial.println("\"hi, i m your postman.\""); Serial.println("\"hi, i m your postman.\"");
Serial.println("-"); Serial.println("-");
Serial.println("- my id: " + String(MY_ID) + ", gid: " + String(MY_GROUP_ID) + ", call me ==> \"" + String(MY_SIGN) + "\""); Serial.println("- my id: " + String(MY_ID) + ", gid: " + String(MY_GROUP_ID) + ", call me ==> \"" + String(MY_SIGN) + "\"");
Serial.println("- mac address: " + WiFi.macAddress() + ", channel: " + String(WIFI_CHANNEL)); Serial.println("- mac address: " + WiFi.macAddress() + ", channel: " + String(WIFI_CHANNEL));
Serial.println("- my peer book ==> \"" + String(ADDRESSBOOK_TITLE) + "\""); Serial.println("- my peer book ==> \"" + String(ADDRESSBOOK_TITLE) + "\"");
#if defined(DISABLE_AP) #if defined(DISABLE_AP)
Serial.println("- ======== 'DISABLE_AP' ========"); Serial.println("- ======== 'DISABLE_AP' ========");
#endif #endif
#if defined(GEN_NOTE_REQ) #if defined(GEN_NOTE_REQ)
Serial.println("- ======== 'GEN_NOTE_REQ' ========"); Serial.println("- ======== 'GEN_NOTE_REQ' ========");
#endif #endif
Serial.println("-"); Serial.println("-");
//wifi //wifi
WiFiMode_t node_type = WIFI_AP_STA; WiFiMode_t node_type = WIFI_AP_STA;
#if defined(DISABLE_AP) #if defined(DISABLE_AP)
// system_phy_set_max_tpw(0); // system_phy_set_max_tpw(0);
WiFi.setTxPower(WIFI_POWER_MINUS_1dBm); // Set WiFi RF power output to lowest level WiFi.setTxPower(WIFI_POWER_MINUS_1dBm); // Set WiFi RF power output to lowest level
node_type = WIFI_STA; node_type = WIFI_STA;
#endif #endif
WiFi.mode(node_type); WiFi.mode(node_type);
//esp-now //esp-now
if (esp_now_init() != 0) { if (esp_now_init() != 0) {
Serial.println("Error initializing ESP-NOW"); Serial.println("Error initializing ESP-NOW");
return; return;
} }
esp_now_register_send_cb(onDataSent); esp_now_register_send_cb(onDataSent);
esp_now_register_recv_cb(onDataReceive); esp_now_register_recv_cb(onDataReceive);
// //
// Serial.println("- ! (esp_now_add_peer) ==> add a 'broadcast peer' (FF:FF:FF:FF:FF:FF)."); // Serial.println("- ! (esp_now_add_peer) ==> add a 'broadcast peer' (FF:FF:FF:FF:FF:FF).");
// uint8_t broadcastmac[6] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF}; // uint8_t broadcastmac[6] = {0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF};
// //
// // // //
// esp_now_peer_info_t peerInfo = {}; // esp_now_peer_info_t peerInfo = {};
// memcpy(peerInfo.peer_addr, broadcastmac, 6); // memcpy(peerInfo.peer_addr, broadcastmac, 6);
// peerInfo.channel = 0; // peerInfo.channel = 0;
// peerInfo.encrypt = false; // peerInfo.encrypt = false;
// esp_now_add_peer(&peerInfo); // esp_now_add_peer(&peerInfo);
AddressBook * book = lib.getBookByTitle(ADDRESSBOOK_TITLE); AddressBook * book = lib.getBookByTitle(ADDRESSBOOK_TITLE);
if (book == NULL) { if (book == NULL) {
Serial.println("- ! wrong book !! : \"" + String(ADDRESSBOOK_TITLE) + "\""); while(1); Serial.println("- ! wrong book !! : \"" + String(ADDRESSBOOK_TITLE) + "\""); while(1);
} }
for (int idx = 0; idx < book->list.size(); idx++) { for (int idx = 0; idx < book->list.size(); idx++) {
Serial.println("- ! (esp_now_add_peer) ==> add a '" + book->list[idx].name + "'."); Serial.println("- ! (esp_now_add_peer) ==> add a '" + book->list[idx].name + "'.");
esp_now_peer_info_t peerInfo = {}; esp_now_peer_info_t peerInfo = {};
memcpy(peerInfo.peer_addr, book->list[idx].mac, 6); memcpy(peerInfo.peer_addr, book->list[idx].mac, 6);
peerInfo.channel = 0; peerInfo.channel = 0;
peerInfo.encrypt = false; peerInfo.encrypt = false;
esp_now_add_peer(&peerInfo); esp_now_add_peer(&peerInfo);
} }
// (DEBUG) fetch full peer list // (DEBUG) fetch full peer list
{ PeerLister a; a.print(); } { PeerLister a; a.print(); }
// //
Serial.println("-"); Serial.println("-");
Serial.println("\".-.-.-. :)\""); Serial.println("\".-.-.-. :)\"");
Serial.println(); Serial.println();
} }
void loop() { void loop() {
// //
runner.execute(); runner.execute();
// //
} }