ゆっくりラズパイ活用講座

　SPEAKER 8Ω　

　Emic2　

　ESP32S2　

GND　

SOUT　

SIN　

　SPEAKER(ー)　

SPー　

　SPEAKER(＋)　

SP＋　

[env:adafruit_qtpy_esp32s2] platform = espressif32 board = adafruit_qtpy_esp32s2 framework = arduino platform_packages = framework-arduinoespressif32 @ https://github.com/espressif/arduino-esp32 build_flags = -DBOARD_HAS_PSRAM -mfix-esp32-psram-cache-issue upload_port = /dev/ttyACM0

void setup() { Serial1.begin(9600); Serial1.print('\n'); while (Serial1.read() != ':'); delay(10); Serial1.flush(); // Set audio volume(dB) Serial1.print("V-10"); Serial1.print("\n"); while (Serial1.read() != ':'); delay(10); Serial1.flush(); // Set speaking rate (words/minute) Serial1.print("W200"); Serial1.print("\n"); while (Serial1.read() != ':'); delay(10); Serial1.flush(); // Select voice Serial1.print("N0"); Serial1.print("\n"); while (Serial1.read() != ':'); delay(10); Serial1.flush(); Serial1.print("S"); Serial1.print("Hello. My name is the Emic 2 Text-to-Speech module."); Serial1.print("\n"); while (Serial1.read() != ':'); delay(10); Serial1.flush(); } void loop() {}

#define SECRET_SSID "XXXXXXXXXXXX"
#define SECRET_PASS "XXXXXXXXXXXXX"

const char* bbc_co_uk_pem = \
"-----BEGIN CERTIFICATE-----\n" \
"MIIDXzCCAkegAwIBAgILBAAAAAABIVhTCKIwDQYJKoZIhvcNAQELBQAwTDEgMB4G" \
"A1UECxMXR2xvYmFsU2lnbiBSb290IENBIC0gUjMxEzARBgNVBAoTCkdsb2JhbFNp" \
"Z24xEzARBgNVBAMTCkdsb2JhbFNpZ24wHhcNMDkwMzE4MTAwMDAwWhcNMjkwMzE4" \
"MTAwMDAwWjBMMSAwHgYDVQQLExdHbG9iYWxTaWduIFJvb3QgQ0EgLSBSMzETMBEG" \
"A1UEChMKR2xvYmFsU2lnbjETMBEGA1UEAxMKR2xvYmFsU2lnbjCCASIwDQYJKoZI" \
"hvcNAQEBBQADggEPADCCAQoCggEBAMwldpB5BngiFvXAg7aEyiie/QV2EcWtiHL8" \
"RgJDx7KKnQRfJMsuS+FggkbhUqsMgUdwbN1k0ev1LKMPgj0MK66X17YUhhB5uzsT" \
"gHeMCOFJ0mpiLx9e+pZo34knlTifBtc+ycsmWQ1z3rDI6SYOgxXG71uL0gRgykmm" \
"KPZpO/bLyCiR5Z2KYVc3rHQU3HTgOu5yLy6c+9C7v/U9AOEGM+iCK65TpjoWc4zd" \
"QQ4gOsC0p6Hpsk+QLjJg6VfLuQSSaGjlOCZgdbKfd/+RFO+uIEn8rUAVSNECMWEZ" \
"XriX7613t2Saer9fwRPvm2L7DWzgVGkWqQPabumDk3F2xmmFghcCAwEAAaNCMEAw" \
"DgYDVR0PAQH/BAQDAgEGMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0OBBYEFI/wS3+o" \
"LkUkrk1Q+mOai97i3Ru8MA0GCSqGSIb3DQEBCwUAA4IBAQBLQNvAUKr+yAzv95ZU" \
"RUm7lgAJQayzE4aGKAczymvmdLm6AC2upArT9fHxD4q/c2dKg8dEe3jgr25sbwMp" \
"jjM5RcOO5LlXbKr8EpbsU8Yt5CRsuZRj+9xTaGdWPoO4zzUhw8lo/s7awlOqzJCK" \
"6fBdRoyV3XpYKBovHd7NADdBj+1EbddTKJd+82cEHhXXipa0095MJ6RMG3NzdvQX" \
"mcIfeg7jLQitChws/zyrVQ4PkX4268NXSb7hLi18YIvDQVETI53O9zJrlAGomecs" \
"Mx86OyXShkDOOyyGeMlhLxS67ttVb9+E7gUJTb0o2HLO02JQZR7rkpeDMdmztcpH" \
"WD9f" \
"-----END CERTIFICATE-----";

#include <Wire.h>
#include <WiFi.h>
#include <WiFiClientSecure.h>
#include <NunniMCAX.h>
#include <datalink.h>

#define SLAVE_ADDR 0x77

WiFiClient       http_client;
WiFiClientSecure https_client;

#define MAXLEN 256
static char m_characters[MAXLEN];
struct NunniMCAXContentHandler handler;
bool RootDetected = false;

typedef struct {
	char    domain[32];
	char    page[32];
	int     port;
} URL_INFO;

URL_INFO url;

#define XML_BUF_SIZE (32768)
typedef struct {
	long  length;
	long  pos;
	char  *buf;
} XML_BUF;

XML_BUF xml;

#define I2C_BUF_SIZE  (32)

void URLAnalyse(char *str)
{
	char *inpt, *outpt;

	if (strncmp(str,"http://",7)==0) {
		url.port =  80;
		inpt = str + 7;
	} else {
		url.port = 443;
		inpt = str + 8;
	}

	for (outpt = url.domain; (*inpt!='/')&&(*inpt!=(char)NULL); outpt++,inpt++) *outpt = *inpt;
	url.page[0] = *inpt; 
	*outpt = (char)NULL;

	for (outpt = &url.page[1],inpt++; *inpt!=(char)NULL; outpt++,inpt++) *outpt = *inpt;
	*outpt = (char)NULL;
}

void getRSS(const char *pem)
{
	char get_cmd[256];
	unsigned long timeout = millis();

	if (url.port == 443) {
		https_client.setCACert(pem);
		if (https_client.connect(url.domain, url.port)) {
			sprintf(get_cmd, "GET https://%s%s HTTP/1.1\r\nHost: %s\r\nUser-Agent: BuildFailureDetectorESP32\r\nConnection: close\r\n\r\n\0", url.domain, url.page, url.domain);
			https_client.print(get_cmd);
			https_client.flush();
			while(https_client.available() == 0){
				if(millis() - timeout > 5000){
					https_client.stop();
					return;
				}
			}
			xml.pos = 0;
			while (1) {
				if (https_client.available() ) {
					xml.buf[xml.pos] = https_client.read();
					xml.pos++;
				}
				if (!https_client.connected()) {
					xml.buf[xml.pos] = EOF;
					xml.length = xml.pos;
					xml.pos = -1;
					break;
				}
			}
		} else {
			return;
		}
	} else {
		if (http_client.connect(url.domain, url.port)) {
			http_client.write("GET /rss/topics/domestic.xml HTTP/1.1\r\n\r\n");
			http_client.flush();
			while(http_client.available() == 0){
				if(millis() - timeout > 5000){
					http_client.stop();
					return;
				}
			}
			xml.pos = 0;
			while (1) {
				if (http_client.available() ) {
					xml.buf[xml.pos] = http_client.read();
					xml.pos++;
				}
				if (!http_client.connected()) {
					xml.buf[xml.pos] = EOF;
					xml.length = xml.pos;
					xml.pos = -1;
					break;
				}
			}
		} else {
			return;
		}
	}

	// パーサーの呼び出し 
	NunniMCAXparse( &getcFunc, &handler );

	if (url.port == 443) {
		https_client.stop();
	} else {
		http_client.stop();
	}
	RootDetected = false;
	delay(5000);

	return;
}

// Ethernetからの1文字読み取るコールバック関数
// 最初の'<'（タグの開始）まで読み飛ばし
//  → HTTPサーバーレスポンス文字を読み飛ばす
int getcFunc()
{
	while(!RootDetected) {
		if (getChar() == '<') {
			RootDetected = true;
			return '<';
		}
	}
	return getChar();
}

int getChar()
{
	xml.pos++;
	return xml.buf[xml.pos];
}

/* SAXパーサーのイベントハンドラー */
int startDocument(void) 
{
	return 0;
}

int startElement( const char *tagname, struct NunniHashtable *args ) 
{
	const int size = NunniHashtableSize( args );
	char ** keys;
	int i, ret;
	const char *name, *value;
	keys = (char**)calloc( size, sizeof( char * ) );

	ret = NunniHashtableKeys( args, keys );
	for ( i = 0; i < size; ++i ) {
		name = keys[i];
		value = NunniHashtableGet( args, name );
	}
	memset( m_characters, 0, MAXLEN );
	free(keys);
	return 0;
}

int characters( char ch[], int start, int length ) 
{
	int i = strlen( m_characters );
	if ( i == MAXLEN ) return -1;
	strncat( m_characters, &(ch[start]), length );
	return 0;
}

int endElement( const char *tagname ) 
{
	int len;
	char *data = m_characters;
	while( isspace( *data ) ) {
		++data;
	}
	len = strlen( data );
	while( isspace( data[--len] ) ) data[len] = 0;
	if ( data != NULL && strncmp( data, "", 1 ) ) {
		if (strncmp(tagname,"description",11)==0) {
			Emic2_speech(data);
			delay(1000);
		}
	}
	memset( m_characters, 0, MAXLEN );
	return 0;
}

int endDocument(void) 
{
	return 0;
}

void Emic2_init()
{
	Serial1.print('\n');
	while (Serial1.read() != ':');
	delay(10);
	Serial1.flush();

	// Set audio volume(dB)
	Serial1.print("V-10");
	Serial1.print("\n");
	while (Serial1.read() != ':');
	delay(10);
	Serial1.flush();

	// Set speaking rate (words/minute)
	Serial1.print("W200");
	Serial1.print("\n");
	while (Serial1.read() != ':');
	delay(10);
	Serial1.flush();

	// Select voice
	Serial1.print("N0");
	Serial1.print("\n");
	while (Serial1.read() != ':');
	delay(10);
	Serial1.flush();
}

void Emic2_speech(char *text)
{
	Serial1.print("S");
	Serial1.print(text);
	Serial1.print("\n");
	while (Serial1.read() != ':');
	delay(10);
	Serial1.flush();
}

void setup()
{
	Wire.begin();
	Serial1.begin(9600);

	WiFi.begin(SECRET_SSID, SECRET_PASS);

	while (WiFi.status() != WL_CONNECTED) delay(500);

	Emic2_init();

	// set up the paser handler functions
	handler.startDocument = startDocument;
	handler.startElement  = startElement;
	handler.characters    = characters;
	handler.endElement    = endElement;
	handler.endDocument   = endDocument;

	xml.buf = (char*)malloc(XML_BUF_SIZE);

	URLAnalyse("https://feeds.bbci.co.uk/news/world/rss.xml");
	getRSS(bbc_co_uk_pem);
}

void loop() {}