Water Detection System นี้คืออะไร?

Project ถูกสร้างขึ้นเพื่อแก้ Pain Point ง่าย ๆ: ถ้าน้ำเริ่มรั่วขณะที่ไม่มีใครอยู่ใกล้บริเวณนั้น ให้ Sensor ตรวจพบเหตุการณ์ แล้วส่ง Notification ออกไปหาเจ้าของ

Use Case ที่ผู้สร้างยกตัวอย่างมีตั้งแต่:

• Basement
• Aquarium
• Water heater
• Pipe
• Sump pump
• Dishwasher
• Washing machine

ใช้ Hardware อะไรบ้าง?

Photon / Spark Core ในปัจจุบันเป็นอย่างไร?

Project ต้นฉบับถูกสร้างในปี 2015 จึงอิง Hardware Ecosystem ของ Particle ในช่วงนั้น

Photon รุ่นดั้งเดิมถูกเลิกผลิตแล้ว และ Particle แนะนำ Hardware รุ่นใหม่กว่าเป็นตัวแทน ขณะที่ Spark Core เป็น Platform รุ่นเก่ากว่า Photon อีกชั้น

Water Leak Sensor ตรวจน้ำอย่างไร?

Source อธิบายแนวคิดแบบง่าย: มี Contact สองฝั่ง และเมื่อ Water Leak Sensor ถูกน้ำสัมผัส สถานะทางไฟฟ้าระหว่าง Contact เปลี่ยนไป

Project ใช้ Internal Pull-up Resistor ของ Particle ดังนั้น Sensor ถูกต่อระหว่าง:

GND ↔ Water Leak Sensor ↔ D0

Firmware อ่าน D0 ด้วย:

INPUT_PULLUP

และ Logic ใน Source ตรวจ:

not digitalRead(FLOOD_SENSOR)

เมื่อ Input ถูก Pull Low Code จึงมองว่าเกิด Flood / Water Detection

ต่อ Water Leak Sensor กับ D0 อย่างไร?

ไม่มี External Pull-up Resistor ใน Logic ของ Project เพราะใช้ Internal Pull-up จาก Particle

น้ำหนึ่งหยดกลายเป็น Notification ได้ยังไง?

Firmware ตรวจ Sensor ทุกกี่วินาที?

Source Code กำหนด:

FLOOD_READ_INTERVAL 2000

หมายถึง Logic ตรวจ Water Leak ถูกเรียกเป็นช่วงประมาณทุก 2 วินาที

เมื่อพบ Water Detection ครั้งแรก:

1. ตั้ง flood_detected = true
2. Reset Alarm Timer
3. ตั้ง Alarm แรกตาม Schedule
4. เปิด LED ที่ D7

ทำไมไม่แจ้งเตือนทุก 2 วินาที?

ถ้าน้ำยังค้างอยู่ การ Push Notification ทุกครั้งที่ Sensor ถูกอ่าน จะทำให้เกิด Alert จำนวนมาก

ผู้สร้างจึงตั้ง Notification Schedule แบบไล่ช่วงเวลา

Particle Firmware ทำงานอย่างไร?

Firmware ต้นฉบับประกอบด้วยสอง Function หลัก:

• flood_check() — อ่าน Water Leak Sensor และควบคุมสถานะ
• flood_notify_user() — Publish Notification ตาม Schedule

Source ระบุ Firmware Version: 0.04

// This #include statement was automatically added by the Particle IDE.
#include "elapsedMillis/elapsedMillis.h"

String _version = "0.04";

//this reads the flood sensor every 2 seconds
#define FLOOD_READ_INTERVAL 2000

//this defines the frequency of the notifications sent to the user
#define FLOOD_FIRST_ALARM 10000 //10 seconds
#define FLOOD_SECOND_ALARM 60000 //1 minute
#define FLOOD_THIRD_ALARM 300000 //5 minutes
#define FLOOD_FOURTH_ALARM 900000 //15 minutes
#define FLOOD_FIFTH_ALARM 3600000 //1 hour
#define FLOOD_SIXTH_ALARM 14400000 //4 hours - and every 4 hours ever after, until the situation is rectified (ie no more water is detected)

#define FLOOD_NOTIF "FLOOD"

elapsedMillis flood_timer;
elapsedMillis flood_alarm_timer;

int flood_alarms_array[6]={
    FLOOD_FIRST_ALARM,
    FLOOD_SECOND_ALARM,
    FLOOD_THIRD_ALARM,
    FLOOD_FOURTH_ALARM,
    FLOOD_FIFTH_ALARM,
    FLOOD_SIXTH_ALARM
};

int flood_alarm_index = 0;
bool flood_detected = false;
unsigned long flood_next_alarm = 0;

int FLOOD_SENSOR = D0;
int LED = D7;

void setup() {
    pinMode(FLOOD_SENSOR, INPUT_PULLUP);
    pinMode(LED, OUTPUT);
    Spark.publish("device starting", "Firmware version: " + _version, 60, PRIVATE);
}

void loop() {

    flood_check();

    if ( flood_detected ) {
        flood_notify_user();
    }
}

/*******************************************************************************
 * Function Name  : flood_check
 * Description    : check water leak sensor at FLOOD_READ_INTERVAL, turns on led on D7 and raises alarm if water is detected
 * Return         : 0
 *******************************************************************************/
int flood_check()
{
    if (flood_timer < FLOOD_READ_INTERVAL) {
        return 0;
    }

    //time is up, so reset timer
    flood_timer = 0;

    if (not digitalRead(FLOOD_SENSOR)) {

        //if flood is already detected, no need to do anything, since an alarm will be fired
        if (flood_detected){
            return 0;
        }

        flood_detected = true;

        //reset alarm timer
        flood_alarm_timer = 0;

        //set next alarm
        flood_alarm_index = 0;
        flood_next_alarm = flood_alarms_array[0];

        digitalWrite(LED,HIGH);

    } else {

        digitalWrite(LED,LOW);
        flood_detected = false;
    }

    return 0;
}

/*******************************************************************************
 * Function Name  : flood_notify_user
 * Description    : will fire notifications to user at scheduled intervals
 * Return         : 0
 *******************************************************************************/
int flood_notify_user()
{

    if (flood_alarm_timer < flood_next_alarm) {
        return 0;
    }

    //time is up, so reset timer
    flood_alarm_timer = 0;

    //set next alarm or just keep current one if there are no more alarms to set
    if (flood_alarm_index < arraySize(flood_alarms_array)-1) {
        flood_alarm_index = flood_alarm_index + 1;
        flood_next_alarm = flood_alarms_array[flood_alarm_index];
    }

    //send an alarm to user (this one goes to the dashboard)
    Spark.publish(FLOOD_NOTIF, "Flood detected!", 60, PRIVATE);

    //send an alarm to user (this one goes to pushbullet servers)
    Spark.publish("pushbullet", "Flood detected!", 60, PRIVATE);

    return 0;
}

Spark.publish() คืออะไร และต่างจาก Particle ปัจจุบันยังไง?

Original Code ใช้:

Spark.publish()

เพื่อ Publish Event ขึ้น Particle Cloud ตัวอย่าง Event สำหรับ Pushbullet คือ:

pushbullet

และ Value คือ:

Flood detected!

Particle Documentation ปัจจุบัน ใช้ Naming ในรูป: Particle.publish()

Webhook เชื่อม Particle กับ Pushbullet อย่างไร?

Firmware ไม่ได้เรียก Pushbullet API โดยตรง แต่ Publish Event ไป Particle Cloud ก่อน

Webhook ที่ตั้งไว้จะตรวจ Event ชื่อ:

pushbullet

แล้วทำ HTTP POST ไปยัง:

https://api.pushbullet.com/v2/pushes

Pushbullet Access Token ต้องระวังอะไร?

ผู้สร้างเตือนไว้ตรง ๆ ว่า Pushbullet Access Token ให้สิทธิ์เข้าถึง Account และไม่ควรแชร์ให้ผู้อื่น

Pushbullet Documentation ปัจจุบัน ยังใช้ Access Token สำหรับ Authentication แต่รูปแบบ Header ที่ยกตัวอย่างใน Documentation ปัจจุบัน ต่างจาก Historical webhook.json ของ Project

webhook.json จากปี 2015 ยังใช้ตรง ๆ ได้ไหม?

ด้านล่างคือ Structure จาก Source ต้นฉบับ โดยเปลี่ยนเฉพาะ Token ตัวอย่าง เป็น Placeholder เพื่อไม่ให้ดูเหมือน Credential จริง

{
  "eventName": "pushbullet",
  "url": "https://api.pushbullet.com/v2/pushes",
  "requestType": "POST",
  "headers": {
    "Authorization": "Bearer YOUR_PUSHBULLET_ACCESS_TOKEN",
    "Content-Type": "application/json"
  },
  "json": {
    "type": "note",
    "title": "{{SPARK_EVENT_VALUE}}",
    "body": ""
  },
  "mydevices": true
}

สร้าง Webhook ผ่าน Particle CLI

Source ใช้ Particle CLI เพื่อ Upload Webhook Configuration จากไฟล์ webhook.json

particle webhook create webhook.json

Command รูปแบบนี้ยังปรากฏใน Particle CLI Documentation ปัจจุบัน สำหรับ User Webhook

เมื่อพบน้ำ ผู้ใช้ได้รับอะไร?

Source ระบุว่าในการทดสอบ เมื่อนำ Water Leak Sensor ไปสัมผัสน้ำ:

1. LED บน Particle Development Kit จะติด
2. ประมาณ 10 วินาทีต่อมา Notification แรกถูกส่ง
3. หากสถานะน้ำยังคงอยู่ Notification จะทำงานตาม Schedule ที่กำหนด

ถ้าต้องตรวจหลายจุดทำได้ไหม?

ผู้สร้างเสนอไว้สองแนวทาง:

1. ต่อ Water Leak Sensor เพิ่มไปยัง Digital Input อื่น แล้วแก้ Firmware ให้รองรับแต่ละ Input
2. ต่อ Sensor หลายตัวในรูปแบบ Parallel ตาม Project อ้างอิงที่ผู้สร้างลิงก์ไว้

Project นี้ตรวจอะไรไม่ได้?

ระบบนี้เป็น Binary Leak / Water Presence Alarm ไม่ใช่เครื่องมือ Measurement แบบต่อเนื่อง

Source ยังไม่ได้ให้:

• Waterproof Enclosure
• Battery Backup
• Wi-Fi Failure Detection
• Sensor Self-test
• Automatic Shutoff Valve
• Alarm Certification
• False-positive / False-negative Test

ถ้าสร้างใหม่วันนี้ควรเรียนรู้อะไรจาก Architecture นี้?

1. Sensor Logic ควรง่าย

Water Detection ไม่จำเป็นต้องเริ่มจาก AI หากโจทย์คือ Binary Event Digital Input หนึ่งขาก็เพียงพอสำหรับต้นแบบ

2. Device ไม่จำเป็นต้องเรียกทุก API เอง

Firmware Publish Event ไป Cloud แล้วใช้ Webhook เป็น Integration Layer ทำให้ Logic ฝั่ง Device เรียบง่ายขึ้น

3. Sensor Polling กับ User Notification ควรแยกกัน

Device ตรวจสถานะทุก 2 วินาทีได้ แต่ผู้ใช้ไม่จำเป็นต้องถูกแจ้งเตือนทุก 2 วินาที

4. Alarm Escalation ช่วยลด Notification Spam

Project เริ่มจาก 10 วินาที แล้วเพิ่มช่วงห่างไปจนถึงทุก 4 ชั่วโมง หากปัญหายังไม่ถูกแก้

5. Credential เป็นส่วนหนึ่งของ Security Design

Pushbullet Access Token ไม่ควรถูกฝังใน Source ที่เผยแพร่สาธารณะ

6. Tutorial เก่าควรแยก Concept ออกจาก Implementation

Architecture ยังน่าเรียนรู้ แต่ Hardware, API, Authentication และ Cloud Schema สามารถเปลี่ยนได้ตามเวลา

โปรเจกต์นี้มีหลายขั้น แนะนำอ่านต้นฉบับควบคู่กัน

หากต้องการทดลองกับ Particle Ecosystem ปัจจุบัน ควรอ่านทั้ง Original Project และ Official Documentation รุ่นล่าสุด โดยเฉพาะเรื่อง Hardware, Publish API, Webhook Schema และ Pushbullet Authentication

FAQ: คำถามที่พบบ่อย

References / แหล่งข้อมูลต้นฉบับ

• Hackster — Water detection system by Gustavo Gonnet
• Particle — Photon Documentation
• Particle — Webhook Reference
• Particle — CLI Reference
• Pushbullet — API Documentation
• Water Leak Sensor Schematic
• Original Particle Firmware Download
• Original Pushbullet Webhook Download