sunucu.py

#!/usr/bin/python2
# -*- coding: utf-8 -*-
import os
from flask import Flask, render_template, session, request
from flask_socketio import SocketIO, emit, disconnect
import irc.bot
import irc.strings
from irc.client import ip_numstr_to_quad, ip_quad_to_numstr
import profil as PROFIL
from random import randint

# async_mode "threading", "eventlet" ,"gevent" olabilir.None olursa kuruşu paketlerden uygun olan seçilir.
async_mode = None

app = Flask(__name__)
app.config['SECRET_KEY'] = 's324fvre7reB!'
socketio = SocketIO(app, async_mode=async_mode)
thread = None

rumuz="milis_"+str(randint(1001,9999))
kanal="#milisarge"
ircsunucu="irc.freenode.net"
ircport=6667

if PROFIL.rumuz != "":
	rumuz = PROFIL.rumuz

if PROFIL.kanal != "":
	kanal = PROFIL.kanal

if PROFIL.ircsunucu != "":
	ircsunucu = PROFIL.ircsunucu
	
if PROFIL.ircport != "":
	ircport = PROFIL.ircport


class MilisBot(irc.bot.SingleServerIRCBot):
    def __init__(self, channel, nickname, server, port=6667):
        irc.bot.SingleServerIRCBot.__init__(self, [(server, port)], nickname, nickname)
        self.channel = channel

    def on_nicknameinuse(self, c, e):
        c.nick(c.get_nickname() + "_")

    def on_welcome(self, c, e):
		c.join(self.channel)
		#mesaj=kanal+" kanalına bağlandınız."
		gonderen=e.source#"Mİ2A2 sunucusu"
		mesaj = e.arguments
		socketio.emit('ircbag_cevap',{'data': mesaj,'gonderen':gonderen},namespace='/irc')
	
    def on_namreply(self, c, e):
		bliste=self.kanal_liste()
		socketio.emit('kanala_gonder_cevap',{'data': "sistem yüklendi.",'gonderen':"Mİ2A2 sunucusu",'kliste':bliste},namespace='/irc')
		
    def on_privmsg(self, c, e):
        print "priv:",c
        print "priv:",e
        self.do_command(e, e.arguments[0])

    def on_pubmsg(self, c, e):
        bliste=self.kanal_liste()
        gonderen = e.source.nick
        mesaj = e.arguments
        socketio.emit('kanala_gonder_cevap',{'data': mesaj,'gonderen':gonderen,'kliste':bliste},namespace='/irc')
        return
            
    def gonder(self,mesaj):
        #self.connection.notice(None,mesaj)
        self.connection.privmsg("#milisarge",mesaj)
    
    def rumuz_bilgi(self,rumuz):
        #self.connection.notice(None,mesaj)
        #self.connection.privmsg("#milisarge","/whois "+rumuz)
        return self.connection.whois(rumuz)
     
    def kanal_liste(self):
		users=[]
		for chname, chobj in self.channels.items():
			users = sorted(chobj.users())
		return users 
	
    def logcek(self):
		komut="cd log && git pull && cd -"
		os.system(komut)
  
'''
def arkaplan_islem():
    # belli periyodlarda olay üretmek için
    sayac = 0
    while True:
        socketio.sleep(10)
        count += 1
        socketio.emit('sunucu_cevap',
                      {'data': 'Sunucu olay üretti', 'count': sayac},
                      namespace='/irc')
'''

bot = MilisBot(kanal,rumuz,ircsunucu,ircport)

def ircbot():
    global bot
    bot.start()
                      
@app.route('/')
def index():
    return render_template('index.html', async_mode=socketio.async_mode)

@socketio.on('sunucu_olay', namespace='/irc')
def sunucu_olay(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('sunucu_cevap',{'data': message['data'], 'count': session['receive_count']})

@socketio.on('sunucu_baglanti_olay', namespace='/irc')
def sunucu_baglanti_olay(message):
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('sunucu_baglanti_cevap',{'data': message['data'], 'count': session['receive_count']})

@socketio.on('kanala_gonder', namespace='/irc')
def kanala_gonder(mesaj):
    global bot
    gonderen=rumuz+" (sen)"
    mesajveri=mesaj['data']
    if mesajveri=="/logcek":
		#mesajveri=bot.rumuz_bilgi("irc_kayitci")
		bot.logcek()
		mesajveri="log cekildi"
    bot.gonder(mesajveri)
    bliste=bot.kanal_liste()
    #emit('kanala_gonder_cevap',{'data': message['data'], 'count': session['receive_count']})
    emit('kanala_gonder_cevap',{'data': mesajveri,'gonderen':gonderen,'kliste':bliste})

@socketio.on('dosya_yukle', namespace='/irc')
def dosya_yukle(mesaj):
    gonderen=rumuz+" (sen)"
    dveri=mesaj["file"]
    disim=mesaj["isim"]
    dosya="/tmp/"+disim
    dosya2="/tmp/link_"+disim+".txt"
    open(dosya,"w").write(dveri)
    os.system("curl -s -F img=@"+dosya+" https://milis-linux.appspot.com/upload > "+dosya2)
    link=open(dosya2,"r").read()
    mesajveri=link.rstrip('\n')
    print link
    global bot
    bot.gonder(mesajveri)
    bliste=bot.kanal_liste()
    emit('kanala_gonder_cevap',{'data': mesajveri,'gonderen':gonderen,'kliste':bliste})

@socketio.on('baglantikes_istegi', namespace='/irc')
def baglantikes_istegi():
    session['receive_count'] = session.get('receive_count', 0) + 1
    emit('sunucu_cevap',{'data': 'Bağlantı kesildi!'})
    disconnect()

@socketio.on('ping_olay', namespace='/irc')
def ping_olay():
    emit('pong_olay')

@socketio.on('connect', namespace='/irc')
def connect():
	global thread
	if thread is None:
		#thread = socketio.start_background_task(target=arkaplan_islem)
		thread = socketio.start_background_task(target=ircbot)
		#socket.io bağlanma iletisi
		emit('sunucu_cevap', {'data': 'Bekleyiniz...', 'count': 0})
	else:
		bliste=bot.kanal_liste()
		socketio.emit('kanala_gonder_cevap',{'data': "sayfa yenilendi.",'gonderen':"Mİ2A2 sunucusu",'kliste':bliste},namespace='/irc')

	
		

'''
@socketio.on('disconnect', namespace='/irc')
def test_disconnect():
    print('Bağlantı kesildi.', request.sid)
'''

if __name__ == '__main__':
    socketio.run(app, host="0.0.0.0",port=7070,debug=True)