Domoticz

Code: Select all

#####in the vDoorBellEventProc######
vFM1188Init
 oss ov9712 init
PAL
dwLuam = 50,dwContr = 50,dwSatuVal = 50
u32ContrVal:50,u32HueVal:50,u32LumaVal:50,u32SatuVal:50
add writeP:2    readP:0
Handle Time:2017-07-07 15:45:57 Cannel:0        Area:0  capNs:1
>>>>  dwMesgPushType = 5
>>>>> push : You have a visitor
#9 cPushString2 = [You have a visitor],dwAlarmType = 13
vCaptureProc start
vStartVGAEncForRecord for 2
COMM_VPSS_StartGroup
COMM_VI_BindVpss
COMM_VPSS_EnableChn
stH264Vbr.u32MaxBitRate = 160
COMM_VENC_BindVpss
vStartVGAEnc
fgAutoCover = 1,dwType = 1
ptAudioSendThread 1278797008 start
start to record to file:fgVGAEncForManualRecordEn = 0,fgRecOn = 1
vRecFileWriteThreadStop!
dwRecOSDWith = 250,dwRecOSDHeight = 24
display region to chn success!
*********fgRecFrameQInit*********
freespace:1828892       totalspace:1949696
create directory path:/mnt/disc1/npc/alarm
RecFileWritethrId 1227687120 start!
cPicName:/mnt/disc1/npc/alarm/2017-07-07/G0000201707071545570101.jpg
****************fgCaptureJPEG OK(1) Len:22837***********************
dwRecord:1
send push signal
get writeP:3    ReadP:0
dool bell path:/mnt/disc1/npc/alarm/2017-07-07/
>>>>> push : You have a visitor
#1 cPushString2 = You have a visitorALARM_NOTIFY_OPTTION2 dwSendSize:172
vCaptureProc not send email!
===>rt_ioctl_giwscan. 1(1) BSS returned, data->length = 149
vNewIrCutHanldeFun to no filter,night
iSetCscLuma val = 50
===>rt_ioctl_giwscan. 1(1) BSS returned, data->length = 149
>>>>  dwMesgPushType = 5

Code: Select all

#!/usr/bin/env python3

import secure_smtpd
import json
import paho.mqtt.client as mqtt
import argparse
import email

from secure_smtpd import SMTPServer, LOG_NAME

parser = argparse.ArgumentParser()
parser.add_argument("-N", "--name", help="doorbell name")
parser.add_argument("-M", "--mqtthost", help="mqtt host")
parser.add_argument("-P", "--mqttport", help="mqtt port", type=int)
parser.add_argument("-U", "--mqttusername", help="mqtt username")
parser.add_argument("-W", "--mqttpassword", help="mqtt password")
args = parser.parse_args()

class SMTPServer(SMTPServer):
    def process_message(self, peer, mailfrom, rcpttos, message_data):
        client = mqtt.Client(client_id="", clean_session=True, userdata=None,
                         protocol=mqtt.MQTTv311)
        client.username_pw_set(args.mqttusername, args.mqttpassword)
        client.connect(args.mqtthost, 1883, 60)
        client.loop_start()
        data = {}
        data['peer'] = peer
        data['mailfrom'] = mailfrom
        data['rcpttos'] = rcpttos
        data['bell'] = 'on'
        json_data = json.dumps(data)
        print (json_data)

        msg = email.message_from_string(message_data)

        attachment = msg.get_payload()[1]
        open('/var/www/html/doorbell/doorbell-1.jpg', 'wb').write(attachment.get_payload(decode=True))
        attachment = msg.get_payload()[2]
        open('/var/www/html/doorbell/doorbell-2.jpg', 'wb').write(attachment.get_payload(decode=True))
        attachment = msg.get_payload()[3]
        open('/var/www/html/doorbell/doorbell-3.jpg', 'wb').write(attachment.get_payload(decode=True))

        client.publish("doorbell/"+args.name, json_data, qos=0)
        client.disconnect()

class FakeCredentialValidator(object):

    def validate(self, username, password):
        return True

server = SMTPServer(
    ('0.0.0.0', 1125),
    None,
    require_authentication=True,
    ssl=False,
    credential_validator=FakeCredentialValidator(),
    process_count=1,
)

print('server run')
server.run()