socketio.js
1.22 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
const db = require('./db.js');
const secret_key = require('./api_option').key;
const requesting = require('request');
module.exports = (server, app) => {
const io = require('socket.io', )(server, {
transports: ['websocket']
});
const API_CALL= setInterval(() => {
requesting.get({
// api를 요청할 주소 -- 시크릿키,위도,경도 입력
url: `https://api2.sktelecom.com/weather/current/minutely?appKey=${secret_key}&lat=37.239795&lon=127.083240`,
json:true
},
//api에게 응답 받았을때 실행되는 callback func
function (err, api_res, api_body) {
if (err) throw err;
// api의 대답이 있을경우 실행
if (api_res) {
console.log(api_body);
return response.send("ok");
}
});
}, 60 * 1000); //1분마다 호출
io.on('connection', (socket) => { //웹 페이지 연결시 루프 동작
socket.on('disconnecting', (reason) => {
clearInterval(API_CALL); //연결 종료시 해제
})
socket.on("connection", (roomnum) => {
API_CALL();
})
})
}