-
Notifications
You must be signed in to change notification settings - Fork 46
Expand file tree
/
Copy pathPump.cpp
More file actions
98 lines (86 loc) · 2.75 KB
/
Pump.cpp
File metadata and controls
98 lines (86 loc) · 2.75 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
#include <Pump.h>
time_t lastPumpStarted;
time_t lastPumpRest;
bool isResting = false;
bool recirculationOn = false;
Pump::Pump(AsyncWebServer *server, ActiveStatus *activeStatus, BrewSettingsService *brewSettingsService) : _server(server),
_activeStatus(activeStatus),
_brewSettingsService(brewSettingsService)
{
_server->on(START_PUMP_SERVIVE_PATH, HTTP_POST, std::bind(&Pump::startPumpHttpService, this, std::placeholders::_1));
_server->on(STOP_PUMP_SERVIVE_PATH, HTTP_POST, std::bind(&Pump::stopPumpHttpService, this, std::placeholders::_1));
}
void Pump::startPumpHttpService(AsyncWebServerRequest *request)
{
TurnPumpOn();
request->send(200, APPLICATION_JSON_TYPE, _activeStatus->GetJson());
}
void Pump::stopPumpHttpService(AsyncWebServerRequest *request)
{
TurnPumpOff();
request->send(200, APPLICATION_JSON_TYPE, _activeStatus->GetJson());
}
void Pump::TurnPumpOn()
{
TurnPump(true);
recirculationOn = true;
lastPumpStarted = now();
lastPumpRest = 0;
CheckRest();
}
void Pump::TurnPumpOff()
{
TurnPump(false);
recirculationOn = false;
lastPumpStarted = 0;
lastPumpRest = 0;
CheckRest();
}
void Pump::TurnPump(bool on)
{
on = _brewSettingsService->InvertPump ? !on : on;
digitalWrite(PUMP_BUS, on ? HIGH : LOW);
_activeStatus->PumpOn = _brewSettingsService->InvertPump ? !on : on;
}
void Pump::CheckRest()
{
if (recirculationOn && !_activeStatus->PIDActing)
{
time_t timeNow = now();
if (!isResting && timeNow - lastPumpStarted >= _brewSettingsService->PumpRestInterval)
{
Serial.println("Pump Rest time to sleep!");
TurnPump(false);
isResting = true;
lastPumpStarted = 0;
lastPumpRest = timeNow;
Buzzer().Ring(1, 50);
}
if (isResting && timeNow - lastPumpRest >= _brewSettingsService->PumpRestTime)
{
Serial.println("Pump Rest wake up!");
TurnPump(true);
isResting = false;
lastPumpRest = 0;
lastPumpStarted = timeNow;
Buzzer().Ring(1, 50);
}
_activeStatus->PumpIsResting = isResting;
}
else
_activeStatus->PumpIsResting = false;
}
void Pump::antiCavitation()
{
if (_activeStatus->ActiveStep == anticavitation)
{
for (byte i = 1; i < 6; i++)
{
TurnPump(true);
delay(1500 + i * 250);
TurnPump(false);
delay(2000);
}
_activeStatus->ActiveStep = _activeStatus->LastActiveStep;
}
}