#include <ESP8266WiFi.h>

char thingSpeakAddress[] = "api.thingspeak.com"; 
unsigned long myChannelNumber = ******; // Channel ID
String myWriteAPIKey = "****************"; // Channel Write API Key
String talkBackID = "*****"; // TalkBack ID
String talkBackAPIKey = "****************"; // TalkBack API Key
String COMMAND_ID ="*******"; // TalkBackで作成したCommand ID
String url = "/talkbacks/"+talkBackID+"/commands/"+COMMAND_ID;
const char* host = "api.thingspeak.com";
String magsw ="0";

char ssid[] = "******";   //  無線LANのSSID 
char pass[] = "******";   // 無線LANのpassword

int status = WL_IDLE_STATUS;
WiFiClient  client;

void setup() {
  Serial.begin(115200);
  WiFi.begin(ssid, pass); // WiFi接続
  pinMode(2, INPUT); // IO2を入力Pinに設定
}

void loop() {
// スイッチが離れ、IO2がHighになったら
// Channel Fieldへの書き込みとTalkBackのコマンドの書き換えを行う
  if (digitalRead(2) == HIGH){ 
    String magsw = "1";
    String commandstr = "SW_ON";
    writefield(magsw); // Channelへのデータ書き込み
    putTalkBack(commandstr); // TalkBackコマンドの変更
  }
  else{
    String magsw = "0";
    String commandstr = "SW_OFF";
    writefield(magsw);
    putTalkBack(commandstr);
  }

  delay(100); // 無料版使用の場合はChannelへの書き込みは15秒に1回に変更。delay(15000)
}

  void putTalkBack(String commandstr) 
 {
    if (client.connect(thingSpeakAddress, 80))
  { 
    Serial.println("Connected to ThingSpeak.");
    Serial.println("talkback post: " + commandstr);
    String tsData = "api_key="+ talkBackAPIKey +"&command_string="+commandstr;
    // talkbackコマンド書き換えのためにhttpコマンド送信
    client.print(String("PUT ") + url + "&headers=false" + " HTTP/1.1\r\n" 
                                      + "Host: " + host + "\r\n"
                                      + "Connection: close\r\n"
                                      + "Content-Type: application/x-www-form-urlencoded\r\n"
                                      + "Content-Length: "+tsData.length()+"\n\n"+tsData+"\n\n");
    client.stop();
    delay(100);
  }
  else
  {
     Serial.println("Connection failed.");
  }
 }

  void writefield(String magsw) 
 {
    if (client.connect(thingSpeakAddress, 80))
  { 
    Serial.println("Connected to ThingSpeak for write field.");
    Serial.println("write data: " + magsw);
    String SWData = "api_key="+ myWriteAPIKey +"&field1="+ magsw;
    //　Channel fieldへのデータ書き込みのためにhttpコマンド送信
    client.print(String("POST /update HTTP/1.1\r\n") 
                                      + "Host: " + host + "\r\n"
                                      + "Connection: close\r\n"
                                      + "Content-Type: application/x-www-form-urlencoded\r\n"
                                      + "Content-Length: "+SWData.length()+"\n\n"+SWData+"\r\n\r\n");
    client.stop();
  }
  else
  {
   Serial.println("Connection failed.");
  }
 }

#include <ESP8266WiFi.h>

const char* ssid     = "***"; // 無線LAN SSID
const char* password = "***"; // 無線LAN password
const char* host = "api.thingspeak.com";
String TalkBackID ="*****"; //Talkback ID
String TalkBackAPIKey ="****************"; // Talkback API key
String Command_ID ="*******"; // Talkbackで作成したコマンドID
// TalkBackコマンド取得のためのURL
String url = "/talkbacks/"+TalkBackID+"/commands/"+Command_ID+"?api_key="+TalkBackAPIKey;

// Use WiFiClient class to create TCP connections
WiFiClient client;
const int ledPin =  13; //Pinの指定IO13

void setup() {
  Serial.begin(115200);
  delay(100);

  // WiFiに接続
  Serial.println();
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);
  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");  
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());

  pinMode(ledPin, OUTPUT);
}

void loop() {

  Serial.print("connecting to ");
  Serial.println(host);

  if (client.connect(host, 80)) {
    Serial.println("Tcp Connection eastablished with thingSpeak API");
  }
  else {
    Serial.println("connection failed");
    return;
  }
  // 接続が確認されたらTalkBackの現在のコマンドの状態を取得する
  client.print(String("GET ") + url + "&headers=false" + " HTTP/1.1\r\n" + "Host: " + host + "\r\n" + "Connection: close\r\n\r\n");

  delay(100); 
  // メッセージの読み取り
  String messageBody = "";
  while (client.available()) {
    String line = client.readStringUntil('\n');
    if (line.length() == 1) { 
      messageBody = client.readStringUntil('\n');
      break;
    }
  }
  // コマンドのON/OFFに応じて出力を変更する
  Serial.print("Found a message, the message is: ");
  if(messageBody == "SW_ON"){
    Serial.print(messageBody);
    digitalWrite(ledPin, HIGH);
  }
  if(messageBody == "SW_OFF"){
    Serial.print(messageBody);
    digitalWrite(ledPin, LOW);
  }

  client.stop();

  Serial.println();
  Serial.println("closing connection");
  Serial.println();
  delay(100);

}