sunucu.py

#!/usr/bin/python2
# -*- coding: utf-8 -*-
import os,time
import copy
import json
import socket
from flask import Flask,redirect,url_for,session
from flask import g
from flask import render_template #render yapmak icin
from flask import request 
from flask import Response
from arge import *
from mps import *
from random import randint
import codecs
import sqlite3 as sqlmak
import subprocess
from htmlrapor import *
import psutil
import sys
#mqtt kullanilirsa
#import paho.mqtt.client as mqtt
import uuid
import threading


dataLock = threading.Lock()
# thread handler
mqtt_thread = threading.Thread()
POOL_TIME = 5 #Seconds

reload(sys)
sys.setdefaultencoding('utf-8')

kurulum="kurulum/kurulum.yml"
ag_bilgi_komut="ifconfig"#"nmcli con show"
arger=Arge()
mps=Mps()
KULL_ID=-1
SECRET_KEY = 'sds234fv'
uxterm_ayar=' -bg black -fg gray -fs 13 '
sanal_konsol_port="6061"

app = Flask(__name__)
app.config.from_object(__name__)


@app.route('/')
def anaModul():
	if "KULL_ID" in session and arger.girdi_kontrol(session['KULL_ID']) :
			return render_template('anaModul.html')
	return redirect(url_for('giris'))

@app.route('/yonlendir/<moduladi>')
def yonlendir(moduladi):
	if "KULL_ID" in session and arger.girdi_kontrol(session['KULL_ID']) :
			return redirect(url_for(moduladi))	
	return redirect(url_for('giris') + "?" + moduladi)	
	
@app.route('/onkar')
def onkar():
	return "python-flask tabanli linux bilgi ve komut yonetim sunucusu- LKomutan"
	#return render_template('anasayfa.html')

@app.route('/cikis')
def cikis():
	arger.girdi_sil(session['KULL_ID'])
	session['KULL_ID']=-1
	return render_template('giris.html')
	
@app.route('/giris', methods=['GET', 'POST'])
def giris():
	error = None
	
	if request.method == 'POST':
		isim=request.form['username']
		sifre=request.form['password']
		onayson=arger.sifre_kontrol(isim,sifre)
		print "giris onayi:",onayson
		if(onayson):
			print isim,"girisi:"
			arger.girdi_ekle(isim)
			print isim,"onaylandi."
			session['KULL_ID']=isim
			return redirect(request.environ["QUERY_STRING"])
		else:
			return redirect("/")	
	return render_template('giris.html', error=error)

@app.route('/giris_eski', methods=['GET', 'POST'])
def giris_eski():
	error = None
	session["KULL_ID"]=-1
	if request.method == 'POST':
		isim=request.form['username']
		sifre=request.form['password']
		id=arger.girdi_no(isim,sifre)
		if(id):
			if arger.girdi_kontrol(id) is None:
				arger.girdi_ekle(id)
			session['KULL_ID']=id
			return render_template('anaModul.html')
	return render_template('giris.html', error=error)

@app.route('/komutaModul', methods=['GET', 'POST'])	
def komutaModul():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		dizin='komuta'
		calismalist=arger.dizin_cek(dizin="komuta")
		return render_template('komutaModul.html',mod=dizin,komutlar=calismalist,kayitmodu='w')	
	else:
		return redirect("/yonlendir/komutaModul")

@app.route('/mpsModul', methods=['GET', 'POST'])	
def mpsModul():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		dizin='/root/talimatname/genel'
		calismalist=arger.dizin_cek(dizin=dizin)
		print "mps module girildi."
		pksunucu=mps.paket_sunucu()
		'''
		try:
			yerel_ip=([(s.connect(('8.8.8.8', 53)), s.getsockname()[0], s.close()) for s in [socket.socket(socket.AF_INET, socket.SOCK_DGRAM)]][0][1])
			s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
			print s.connect((yerel_ip,int(sanal_konsol_port)))
		except socket.error, e:
			print "dahili"
		#except socket.error, e:
		os.system("python3 butterfly/butterfly.server.py --unsecure --host=0.0.0.0 --port="+sanal_konsol_port)
		'''
		return render_template('mps.html',mod=dizin,komutlar=calismalist,kayitmodu='w',pksunucu=pksunucu)	
	else:
		return redirect("/yonlendir/mpsModul")

@app.route('/mpsFaal', methods=['GET', 'POST'])
def mpsFaal():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		rapor="bos"
		if 'faal' in request.args:
			faal = request.args.get('faal')
			paket=request.form["paketadi"]
			if paket!="":
				if faal=="bilgi":	
					talimatname="/sources/milis.git/talimatname" 
					bulkomut="find "+talimatname+" -name "+paket
					talimat=arger.komutCalistir(bulkomut)
					talimat=talimat.rstrip()+"/talimat"
					rapor=open(talimat,"r").read()
				if faal=="kur":
					#os.system('uxterm '+uxterm_ayar+' -e "mps -kur '+paket+' && sleep 3 && exit" ') 
					rapor=mps.paket_kur(paket)
				if faal=="sil":
					rapor=mps.paket_sil(paket)
				if faal=="guncelle":
					rapor=mps.paket_guncelle(paket)
			else:
				rapor="boş paket"
		else:
			rapor="parametre eksik"
		return Response(json.dumps(rapor),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/kurulum', methods=['GET', 'POST'])	
def kurulum():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		dizin="kurulum"
		kadlar=arger.dizin_cek(dizin="kurulum")
		diskler=arger.diskler(tip="ext4")
		takaslar=arger.diskler(tip="swap")
		return render_template('kurulum.html',kadlar=kadlar,diskler=diskler,takaslar=takaslar)	
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")

@app.route('/kadbilgi_islem', methods=['GET', 'POST'])
def kadbilgi_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		kad=request.form["kadlar"]
		data=arger.kurulum_oku(kad)
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/kadkaydet_islem', methods=['GET', 'POST'])
def kadkaydet_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		kad=request.form["kadlar"]
		kurulumbolum=request.form["kurulumbolum"]
		bolumformat=request.form["bolumformat"]
		kullisim=request.form["kullisim"]
		kullsifre=request.form["kullsifre"]
		grubkur=request.form["grubkur"]
		takasalani=request.form["takasalani"]
		if grubkur != "evet" and grubkur != "hayir":
			data="Grub Kurulum için belirsiz seçim" 
		elif bolumformat != "evet" and bolumformat != "hayir":
			data="Bölüm Formatlama için belirsiz seçim"
		else:
			kparam=arger.kurulum_oku(kad)
			kparam["disk"]["bolum"]=str(kurulumbolum)
			kparam["disk"]["format"]=str(bolumformat)
			kparam["disk"]["takasbolum"]=str(takasalani)
			kparam["kullanici"]["isim"]=str(kullisim)
			kparam["kullanici"]["sifre"]=str(kullsifre)
			kparam["grub"]["kur"]=str(grubkur) 
			arger.kurulum_yaz(kparam,kad)
			data="tamam"
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/test_islem', methods=['GET', 'POST'])
def test_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		if('islem' in request.args):
			islem = request.args.get('islem')
			print islem
			data=islem+" islendi"
			time.sleep(3)
		#kurulum uygulaması buraya kodlanacak.
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/kaduygula_islem', methods=['GET', 'POST'])
def kaduygula_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		sonuc=""
		islem = request.args.get('islem')
		dosya = request.args.get('kad')
		kurulum=arger.kurulum_oku(dosya)
		kbolum=kurulum["disk"]["bolum"]
		kformat=kurulum["disk"]["format"]
		kbaglam=kurulum["disk"]["baglam"]
		ktakas=kurulum["disk"]["takasbolum"]
		kisim=kurulum["kullanici"]["isim"]
		ksifre=kurulum["kullanici"]["sifre"]
		kgrubkur=kurulum["grub"]["kur"]
		#formatlama
		if islem == "formatlama":
			if kformat == "evet":
				sonuc=arger.bolumFormatla(kbolum)
				if sonuc:
					data=kbolum+" formatlandı."
		#takas ayarlanması
		elif islem == "takas":
			if ktakas !="":
				sonuc=arger.takasAyarla(ktakas)
				if sonuc:
					data=ktakas+" takas alanı ayarlandı."
		#kurulacak bölümün bağlanması
		elif islem == "baglama":
			sonuc=arger.bolumBagla(kbolum,kbaglam)
			if sonuc:
				data=kbolum+" "+kbaglam+" altına baglandı."
		#kullanıcı oluşturma
		elif islem == "kullanici":
			sonuc=arger.kullaniciOlustur(kisim,kisim,ksifre)
			if sonuc:
				data=kisim+" kullanıcısı oluşturuldu."
		#sistemin kopyalanması
		elif "_" in islem:
			dizin=islem[1:]
			if "usr" in dizin:
				os.system("mkdir -p "+kbaglam+"/usr")
				sonuc=arger.dizinKopyala(dizin,kbaglam+"/usr")
			else:
				sonuc=arger.dizinKopyala(dizin,kbaglam)
			if sonuc:
				data=dizin+" kopyalandı."
		elif islem == "kopyalama":
			sonuc=arger.sistemOlustur(kbaglam)
			if sonuc:
				data="sistem kopyalandı."
		#initrd oluşturulması
		elif islem == "baslatici":
			sonuc=arger.initrdOlustur(kbaglam)
			if sonuc:
				data="initrd oluşturuldu."
		#grub kurulması
		elif islem == "grub":
			if kgrubkur == "evet":
				sonuc=arger.grubKur(kbolum,kbaglam)
				if sonuc:
					data="grub kuruldu."
		elif islem == "cozme":
			sonuc=arger.bolumCoz(kbolum)
			if sonuc:
				data="Milis İşletim Sistemi başarıyla kuruldu."
		else:
			print("hata:",islem)
			data=islem+" hatalidir!"
		if sonuc is not True:
			data=sonuc
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/diskbilgi', methods=['GET', 'POST'])
def diskbilgi():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		disk=request.form["kurdisk"]
		os.system("df -h | grep "+str(disk)+" > kondarma/diskbilgi")
		diskbilgi=open("kondarma/diskbilgi","r").read()
		data+=diskbilgi
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/disksil_islem', methods=['GET', 'POST'])
def disksil_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		disk=request.form["kurdisk"]
		#disk silinir.
		data="tamam"
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/diskbol_islem', methods=['GET', 'POST'])
def diskbol_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		#ilgili bolumleme programı açılır.
		os.system("gparted") 
		data="tamam"
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")
		

@app.route('/kull_islem', methods=['GET', 'POST'])
def kull_islem():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		kull_komut="ko"  
		os.system('uxterm '+uxterm_ayar+' -e "'+kull_komut+' && sleep 3 && exit" ') 
		#os.system("killall uxterm")
		data="tamam"
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/paketlist', methods=['GET', 'POST'])
def paketlist():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=os.listdir("/root/talimatname/genel")
		lst = []
		for pn in data:
			d = {}
			d['isim']=pn
			lst.append(d)
		if lst:
			return Response(json.dumps(lst),mimetype='application/json')
		else:
			return Response(json.dumps("hata"),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/paketvtGuncelle', methods=['GET', 'POST'])
def paketvtGuncelle():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		rapor=mps.paketvt_guncelle()
		return Response(json.dumps(rapor),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/gitGuncelle', methods=['GET', 'POST'])
def gitGuncelle():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		rapor=mps.git_guncelle()
		return Response(json.dumps(rapor),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	

@app.route('/paketDurum', methods=['GET', 'POST'])
def paketdurum():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data="yok"
		paket=request.form["paketadi"]
		if paket!="":
			komut="mps -kk "+paket
			cikti=arger.komutCalistir(komut)
			if "kurulu" in cikti:
				data="kurulu"
			elif "degil" in cikti:
				data="degil"
			else:
				data="tanimsiz"
		else:
			data="tanimsiz"
		
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	


@app.route('/surecModul', methods=['GET', 'POST'])	
def surecModul():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		surecler=arger.komut_kos("netstat -natplu","sh")
		surecler=surecler.split("\n")
		'''rapor="<html><table  border=1  align=left>"
		for surec in surecler:
			if "Active" not in surec and "Proto" not in surec: 
				rapor+="<tr>"
				for sur in surec.split():
					rapor+="<td>"+sur+"</td>"
				rapor+="</tr>"
		rapor+="</table></html>"'''
		rapor=statikrapor()
		dizibas=[]
		top_sutlar=[]
		rapor_html=rapor.diziYhtml2(surecler,dizibas,top_sutlar)
		rapor=rapor_html
		return render_template('surecModul.html')+rapor
	else:
		return redirect("/yonlendir/surecModul")
		
@app.route('/arayuzModul', methods=['GET', 'POST'])	
def arayuzModul():
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		dizin='templates'
		arayuzlist=arger.dizin_cek(dizin="templates")
		return render_template('arayuzModul.html',mod=dizin,arayuzler=arayuzlist,kayitmodu='w')	
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/rehberModul', methods=['GET', 'POST'])	
def rehberModul():
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		dizin='rehber'
		#mqtt aktifse
		#client.connect("test.mosquitto.org",1883,60)
		#client.publish('milislinux/komutan/rehber', kimlik+' rehberi yenilendi.')
		rehberlist=arger.dizin_cek(dizin="rehber")
		depolar=arger.dizin_cek(dizin="rehber/depolar")
		rehberlist2=arger.gitdepo_dosyalar()
		return render_template('rehberModul.html',rehberler=rehberlist,mod=dizin,kayitmodu='w',depolar=depolar,rehberler2=rehberlist2)
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/komutanAyarlar', methods=['GET', 'POST'])	
def komutanAyarlar():
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		aplanlar=arger.dizin_cek(dizin="static/bootstrap/img")
		aplanlist=[]
		for aplan in aplanlar:
			aplanlist.append("/static/bootstrap/img/"+aplan)
		return render_template('komutanAyarlar.html',kayitmodu='w',aplanlar=aplanlist)
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/komutanAyarIslem', methods=['GET', 'POST'])	
def komutanAyarIslem():
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		ayarlar=""
		data=""
		islem = request.args.get('islem')
		dosya = request.args.get('dosya')
		if islem == "aplan_degistir":
			if dosya != "":
				ayarlar="body { "+"\n"
				ayarlar+="background: url('/static/bootstrap/img/"+dosya+"') no-repeat center center fixed;"+"\n"
				ayarlar+="-webkit-background-size: cover;" + "\n"
				ayarlar+="-moz-background-size: cover;" + "\n"
				ayarlar+="background-size: cover;" + "\n"
				ayarlar+="-o-background-size: cover;" + "\n"
				ayarlar+="margin: 20px 20px 20px 20px;" + "\n"
				ayarlar+="}"
				open("static/bootstrap/css/ayarlar.css","w").write(ayarlar)
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")	
		
@app.route('/rehberdepoEkle', methods=['GET', 'POST'])	
def rehberdepoEkle():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		depo_adres=request.form["rehberdepo"]
		data=arger.gitdepo_ekle(depo_adres)
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")

@app.route('/rehberdepoGuncelle', methods=['GET', 'POST'])	
def rehberdepoGuncelle():
	if "KULL_ID" not in session:
		session['KULL_ID']=-1
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		data=""
		depo_adres=request.form["rehberdepo"]
		data=arger.gitdepo_ekle(depo_adres,mod="g")
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")		

@app.route('/rehberOku', methods=['GET', 'POST'])
def rehberOku():
	onay=1
	if(onay==1):
		dizin="rehber"
		dizin2="rehber/depolar/"
		if "dosya" in request.args:
			dosya = request.args.get('dosya')
			if "/" in dosya:
				data=codecs.open(dizin2+"/"+dosya,"r").read()
			else:
				data=codecs.open(dizin+"/"+dosya,"r").read()
		return Response(json.dumps(data),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")
		
@app.route('/komutanGuncelle', methods=['GET', 'POST'])	
def komutanGuncelle():
	girdimi=arger.girdi_kontrol(session['KULL_ID'])
	if ("KULL_ID" in session and girdimi) :
		log=""
		os.system("./guncelle.sh")
		#log=open("log/guncelleme.log","r").read()
		return "<html>güncellendi:<p>"+log+"<p><a href='/'>ana sayfa</a> </html>"
	else:
		return redirect("/yonlendir/komutanGuncelle")

@app.route('/komutCalistir', methods=['GET', 'POST'])
def komutCalistir():
	onay=1
	if(onay==1):
		komut=request.form["calismakod"]
		komutson=""
		onkomut=""
		komutdos=request.form["calismalist"]
		if ".sh" in komutdos:
			komut=komut.split("\n")
			for kom in komut:
				komek=kom
				if '=' in kom and 'if ' not in kom:
					baslik=kom.split('=')[0]
					deger=kom.split('=')[1]
					ydeger=request.form[baslik]
					komek=baslik+"="+str(ydeger)
				komutson+=komek+"\n"
			onkomut=""
		else:
			komutson=komut
		if "#python" in komut:
			onkomut="python "
		
		sonuc=arger.komut_kos(komutson,onkomut)
		return Response(json.dumps(sonuc),mimetype='application/json')
	else:		
		return render_template('giris.html', error="isim ve sifre giriniz")

@app.route('/calismaAl', methods=['GET', 'POST'])
def calismaAl():
	onay=1
	if(onay==1):
		if('mod' in request.args):
			dizin = request.args.get('mod')
		else:
			dizin='komuta'
		if('dosya' in request.args):
			dosya = request.args.get('dosya')
		else:
			dosya='test.sh'
		try:
			data=codecs.open(dizin+"/"+dosya,"r").read()
			return Response(json.dumps(data),mimetype='application/json')
		except:
			return Response(json.dumps("hata"),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")


@app.route('/calismaKaydet', methods=['GET', 'POST'])
def calismaKaydet():
	onay=1
	if(onay==1):
		kayitmodu = request.form['kayitmodu']
		komut = request.form['calismakod']
		if(kayitmodu=='w'):
			dosya = request.form['yenicalisma']
		else:
			dosya = request.form['calismalist']
		dizin = request.form['mod']
		test=codecs.open(dizin+"/"+dosya,"w","utf-8").write(komut)
		test=codecs.open("/tmp/komutan_islem","w","utf-8").write(komut)
		sonuc="tamam"
		#os.system("yapistir-ix.io.sh /tmp/komutan_islem > /tmp/komutan_islem_link")
		#client.connect("test.mosquitto.org",1883,60)
		#client.publish('milislinux/komutan/'+dizin, kimlik+' '+dizin+' islemi.')
		#client.publish('milislinux/komutan/'+dizin, kimlik+' '+open("/tmp/komutan_islem_link","r").read()+' linki.')
		return Response(json.dumps(sonuc),mimetype='application/json')
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")
	
@app.route('/agModul')
def agModul():
	
	return render_template('ag.html')

@app.route('/raporModul')
def raporModul():
	
	return render_template('rapor.html')
	

@app.route('/arayuzModul_eski', methods=['GET', 'POST'])
def arayuzModul_eski():
	onay=1
	if(onay==1):
		html="<html>"
		komutdos = request.args.get('kd')#"komuta/paket_kur.sh"
		komut=codecs.open("komuta/"+komutdos,"r",'utf-8').read()
		komut=komut.split("\n")
		html+=komutdos+"<p>"
		for kom in komut:
			if '=' in kom and 'if' not in kom:
				deger=kom.split('=')[1]
				deguz=len(kom.split('=')[1])*8+10
				html+=kom.split('=')[0]+":"+"<input type=text id="+kom.split('=')[0]+" name="+kom.split('=')[0]+"  value="+deger+" tabindex='-1' style='width:"+str(deguz)+"px;'/>"+"<br>"
		html+="<p>"+"<input type='submit' name='calistir' id='calistir' value='betik_kos' tabindex='-1'/>"+"<p>"
		html+="<a href='/'><img src='/static/ana.png' class='hover' hinttext='anasayfa' style='margin-right:120px;'></a>" 
		html+="<a href='/komutaModul'><img src='/static/komuta.png' class='hover' hinttext='komuta' style='margin-right:120px;'></a>" 
		html+=""+"</html>"
		return html
	else:
		return render_template('giris.html', error="isim ve sifre giriniz")

@app.route('/ag_bilgi', methods=['GET', 'POST'])
def ag_bilgi():
	onay=1
	if(onay==1):
		#rapor="AG BILGILERI<br>"
		fname="agModul.kom"
		komutsan=""
		rapor="<html>"
		with open(fname) as f:
			ag_komutdos = f.readlines()
		for komutdos in ag_komutdos:
			komutson="<strong>"+komutdos.strip()+"</strong><br>"+arger.komut_doskos(komutdos.strip())
			rapor+=komutson+"<br>"
		rapor+="</html>"
		return Response(json.dumps(rapor),mimetype='application/json')
	return render_template('giris.html', error="isim ve sifre giriniz")

def on_connect(client, userdata, flags, rc):

    client.subscribe("+/milislinux/komutan")
    client.subscribe("+/milislinux/komutan/rehber")    

def on_message(mosq, obj, msg):
    global message
    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
    message = msg.payload

def on_publish(mosq, obj, mid):
    print("mid: " + str(mid))

def on_subscribe(mosq, obj, mid, granted_qos):
    print("abonelik: " + str(mid) + " " + str(granted_qos))

def on_log(mosq, obj, level, string):
    print(string)

def mqtt_islem():
        global mqtt_thread
        with dataLock:
			os.system("python mqtt_sun.py")
        mqtt_thread = threading.Timer(POOL_TIME, mqtt_islem, ())
        mqtt_thread.start()   

def mqtt_islem_basla():
	global mqtt_thread
	mqtt_thread = threading.Timer(POOL_TIME,mqtt_islem, ())
	mqtt_thread.start()

@app.route('/veri_cek', methods= ['GET'])
def veri_cek():
	veri=""
	#veri=open("log/mqtt.log","r").read()
	
	return Response(json.dumps(veri),mimetype='application/json')

if __name__ == '__main__':
	print "komutan sunucu calisiyor:"
	os.system("mkdir -p log")
	#mqtt haberleşme için kullanılacak.
	'''
	mqtt_islem_basla()
	
	if os.path.isfile("uuid"): 
		kimlik=open("uuid","r").read()
	else:
		kimlik= uuid.uuid4()
		kimlik=str(kimlik)
		open("uuid","w").write(kimlik)
	client = mqtt.Client()
	client.on_connect = on_connect
	client.on_message = on_message
	client.on_publish = on_publish
	client.on_subscribe = on_subscribe
	client.connect("test.mosquitto.org",1883,60)
	#client.connect("m2m.eclipse.org",1883,60)
	#client.connect("iot.eclipse.org",1883,60)
	client.loop(2)
	'''
	host="0.0.0.0"
	port_calis=6060
	#
	sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	try:
		sock.connect_ex((host,port_calis))
		app.run(host=host,port=port_calis,debug=False,use_evalex=True,threaded=True) 
	except Exception, e:
		if "Errno 98" in str(e):
			os.system("fuser -k "+str(port_calis)+"/tcp")
			print "Komutan zaten çalışıyor.Port kullanımda."