queue in editor integrated - not yet fully functioning

README.MD

@@ -12,10 +12,9 @@ django-admin startproject demo
 ## install an app
 python3 manage.py startapp migration
 
+python3 manage.py createsuperuser
+python3 manage.py migrate
+
 -- Django calling Rest Services ? 
-
-python3 manage.py newproject demo
-
-
 python3 manage.py runserver
 

app/address.py

@@ -0,0 +1,66 @@
+import tkinter as tk
+
+# Create a new window with the title "Address Entry Form"
+window = tk.Tk()
+window.title("Address Entry Form")
+
+# Create a new frame `frm_form` to contain the Label
+# and Entry widgets for entering address information
+frm_form = tk.Frame(relief=tk.SUNKEN, borderwidth=3)
+# Pack the frame into the window
+frm_form.pack()
+
+# List of field labels
+labels = [
+    "First Name:",
+    "Last Name:",
+    "Address Line 1:",
+    "Address Line 2:",
+    "City:",
+    "State/Province:",
+    "Postal Code:",
+    "Country:",
+]
+
+# Loop over the list of field labels
+for idx, text in enumerate(labels):
+    # Create a Label widget with the text from the labels list
+    label = tk.Label(master=frm_form, text=text)
+    # Create an Entry widget
+    entry = tk.Entry(master=frm_form, width=50)
+    # Use the grid geometry manager to place the Label and
+    # Entry widgets in the row whose index is idx
+    label.grid(row=idx, column=0, sticky="e")
+    entry.grid(row=idx, column=1)
+
+# Create a new frame `frm_buttons` to contain the
+# Submit and Clear buttons. This frame fills the
+# whole window in the horizontal direction and has
+# 5 pixels of horizontal and vertical padding.
+frm_buttons = tk.Frame()
+frm_buttons.pack(fill=tk.X, ipadx=5, ipady=5)
+
+# Create an event handler
+def handle_keypress(event):
+    """Print the character associated to the key pressed"""
+    print(event.char)
+
+# Bind keypress event to handle_keypress()
+window.bind("<Key>", handle_keypress)
+
+def handle_click(event):
+    print("Adress was submitted")
+
+# Create the "Submit" button and pack it to the
+# right side of `frm_buttons`
+btn_submit = tk.Button(master=frm_buttons, text="Submit")
+btn_submit.pack(side=tk.RIGHT, padx=10, ipadx=10)
+btn_submit.bind("<Button-1>", handle_click)
+
+# Create the "Clear" button and pack it to the
+# right side of `frm_buttons`
+btn_clear = tk.Button(master=frm_buttons, text="Clear")
+btn_clear.pack(side=tk.RIGHT, ipadx=10)
+
+# Start the application
+window.mainloop()

app/basic.py

@@ -0,0 +1,47 @@
+import tkinter as tk
+
+window = tk.Tk()
+label = tk.Label(
+    text="Python rocks!",
+    foreground="white",  # Set the text color to white
+    background="black"  # Set the background color to black
+)
+
+border_effects = {
+    "flat": tk.FLAT,
+    "sunken": tk.SUNKEN,
+    "raised": tk.RAISED,
+    "groove": tk.GROOVE,
+    "ridge": tk.RIDGE,
+}
+for relief_name, relief in border_effects.items():
+    frame = tk.Frame(master=window, relief=relief, borderwidth=5)
+    frame.pack(side=tk.LEFT)
+    label = tk.Label(master=frame, text=relief_name)
+    label.pack()
+    
+label.pack()
+entry = tk.Entry()
+entry.pack()
+
+name = entry.get()
+
+frame_a = tk.Frame()
+
+
+label_a = tk.Label(master=frame_a, text="Personalliste")
+label_a.pack()
+
+frame_a.pack()
+
+text_box = tk.Text()
+text_box.pack()
+
+frame_b = tk.Frame()
+label_b = tk.Label(master=frame_b, text="I'm in Frame B")
+label_b.pack()
+frame_b.pack()
+
+
+window.mainloop()
+print(name)

app/config.py

@@ -0,0 +1,2 @@
+username = 'mqadmin'
+password = '3Mnj29jKBsFybc'

app/dice.py

@@ -0,0 +1,17 @@
+import random
+import tkinter as tk
+
+def roll():
+    lbl_result["text"] = str(random.randint(1, 6))
+
+window = tk.Tk()
+window.columnconfigure(0, minsize=150)
+window.rowconfigure([0, 1], minsize=50)
+
+btn_roll = tk.Button(text="Roll", command=roll)
+lbl_result = tk.Label()
+
+btn_roll.grid(row=0, column=0, sticky="nsew")
+lbl_result.grid(row=1, column=0)
+
+window.mainloop()

app/edit.py

@@ -0,0 +1,86 @@
+import tkinter as tk
+import config as conf
+import pika
+
+from tkinter.filedialog import askopenfilename, asksaveasfilename
+
+def send_queue_message(exchange_name):
+    credentials= pika.PlainCredentials(username= conf.username, password= conf.password)
+    connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
+    channel= connection.channel()
+    channel.exchange_declare(exchange = exchange_name, durable=True, exchange_type='topic')
+    channel.queue_declare(queue = 'AllInfo')
+    channel.queue_bind(exchange = exchange_name, queue='AllInfo', routing_key='All')
+    message = txt_edit.get("1.0", tk.END)
+
+    channel.basic_publish(exchange = exchange_name, routing_key = 'All', body = message)
+    channel.close()
+
+def get_queue_message(exchange_name):
+    credentials= pika.PlainCredentials(username= conf.username, password= conf.password)
+    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
+    channel = connection.channel()
+    channel.exchange_declare(exchange_name, durable=True, exchange_type='topic')
+    txt_edit.delete("1.0", tk.END)
+    
+    def callbackFunctionForQueue(ch,method,properties,body):
+        message = 'Message from Queue Part: ' + body.decode("utf-8")
+        txt_edit.insert(tk.END, message)
+        ch.basic_ack(delivery_tag = method.delivery_tag)
+        
+    # Display the message parts
+    channel.basic_consume(queue='AllInfo', on_message_callback=callbackFunctionForQueue, auto_ack=True)
+
+    # Close the channel and the connection
+    channel.close()
+    connection.close()
+
+def open_file():
+    """Open a file for editing."""
+    filepath = askopenfilename(
+        filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")]
+    )
+    if not filepath:
+        return
+    txt_edit.delete("1.0", tk.END)
+    with open(filepath, mode="r", encoding="utf-8") as input_file:
+        text = input_file.read()
+        txt_edit.insert(tk.END, text)
+    window.title(f"Simple Text Editor - {filepath}")
+
+def save_file():
+    """Save the current file as a new file."""
+    filepath = asksaveasfilename(
+        defaultextension=".txt",
+        filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")],
+    )
+    if not filepath:
+        return
+    with open(filepath, mode="w", encoding="utf-8") as output_file:
+        text = txt_edit.get("1.0", tk.END)
+        output_file.write(text)
+    window.title(f"Simple Text Editor - {filepath}")
+
+window = tk.Tk()
+window.title("Simple Text Editor")
+
+window.rowconfigure(0, minsize=800, weight=1)
+window.columnconfigure(1, minsize=800, weight=1)
+exchange_name = 'simple-editor'
+
+txt_edit = tk.Text(window)
+frm_buttons = tk.Frame(window, relief=tk.RAISED, bd=2)
+btn_open = tk.Button(frm_buttons, text="Open", command=open_file)
+btn_save = tk.Button(frm_buttons, text="Save As...", command=save_file)
+btn_send = tk.Button(frm_buttons, text="Send", command=send_queue_message(exchange_name))
+btn_receive = tk.Button(frm_buttons, text="Receive", command=get_queue_message(exchange_name))
+
+btn_open.grid(row=0, column=0, sticky="ew", padx=5, pady=5)
+btn_save.grid(row=1, column=0, sticky="ew", padx=5)
+btn_send.grid(row=2, column=0, sticky="ew", padx=5, pady=5)
+btn_receive.grid(row=3, column=0, sticky="ew", padx=5, pady=5)
+
+frm_buttons.grid(row=0, column=0, sticky="ns")
+txt_edit.grid(row=0, column=1, sticky="nsew")
+
+window.mainloop()

app/queue_consumer.py

@@ -0,0 +1,22 @@
+import pika, time, config
+#declaring the credentials needed for connection like host, port, username, password, exchange etc
+credentials= pika.PlainCredentials(username= config.username, password= config.password)
+connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
+channel = connection.channel()
+channel.exchange_declare('pydev', durable=True, exchange_type='topic')
+#defining callback functions responding to corresponding queue callbacks
+def callbackFunctionForQueueA(ch,method,properties,body):
+ print('Got a message from Queue A: ', body)
+def callbackFunctionForQueueB(ch,method,properties,body):
+ print('Got a message from Queue B: ', body)
+def callbackFunctionForQueueC(ch,method,properties,body):
+ print('Got a message from Queue C: ', body)
+#Attaching consumer callback functions to respective queues that we wrote above
+channel.basic_consume(queue='A', on_message_callback=callbackFunctionForQueueA, auto_ack=True)
+channel.basic_consume(queue='B', on_message_callback=callbackFunctionForQueueB, auto_ack=True)
+channel.basic_consume(queue='C', on_message_callback=callbackFunctionForQueueC, auto_ack=True)
+#this will be command for starting the consumer session
+channel.start_consuming()
+##time.sleep(2)
+##channel.stop_consuming()
+channel.close()

app/queue_producer.py

@@ -0,0 +1,21 @@
+import pika, config
+#declaring the credentials needed for connection like host, port, username, password, exchange etc
+credentials= pika.PlainCredentials(username= config.username, password= config.password)
+connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
+channel= connection.channel()
+channel.exchange_declare(exchange='pydev', durable=True, exchange_type='topic')
+channel.queue_declare(queue= 'A')
+channel.queue_bind(exchange='pydev', queue='A', routing_key='A')
+channel.queue_declare(queue= 'B')
+channel.queue_bind(exchange='pydev', queue='B', routing_key='B')
+channel.queue_declare(queue= 'C')
+channel.queue_bind(exchange='pydev', queue='C', routing_key='C')
+#messaging to queue named C
+message_spec= 'Only this channel can see this message'
+message_all= 'Welcome to python queue handling...'
+channel.basic_publish(exchange='pydev', routing_key='A', body= message_all)
+channel.basic_publish(exchange='pydev', routing_key='B', body= message_all)
+channel.basic_publish(exchange='pydev', routing_key='C', body= message_all)
+channel.basic_publish(exchange='pydev', routing_key='B', body= message_spec)
+channel.basic_publish(exchange='pydev', routing_key='C', body= message_spec)
+channel.close()

app/temp.py

@@ -0,0 +1,41 @@
+import tkinter as tk
+
+def fahrenheit_to_celsius():
+    """Convert the value for Fahrenheit to Celsius and insert the
+    result into lbl_result.
+    """
+    fahrenheit = ent_temperature.get()
+    celsius = (5 / 9) * (float(fahrenheit) - 32)
+    lbl_result["text"] = f"{round(celsius, 2)} \N{DEGREE CELSIUS}"
+
+# Set up the window
+window = tk.Tk()
+window.title("Temperature Converter")
+window.resizable(width=False, height=False)
+
+# Create the Fahrenheit entry frame with an Entry
+# widget and label in it
+frm_entry = tk.Frame(master=window)
+ent_temperature = tk.Entry(master=frm_entry, width=10)
+lbl_temp = tk.Label(master=frm_entry, text="\N{DEGREE FAHRENHEIT}")
+
+# Layout the temperature Entry and Label in frm_entry
+# using the .grid() geometry manager
+ent_temperature.grid(row=0, column=0, sticky="e")
+lbl_temp.grid(row=0, column=1, sticky="w")
+
+# Create the conversion Button and result display Label
+btn_convert = tk.Button(
+    master=window,
+    text="\N{RIGHTWARDS BLACK ARROW}",
+    command=fahrenheit_to_celsius
+)
+lbl_result = tk.Label(master=window, text="\N{DEGREE CELSIUS}")
+
+# Set up the layout using the .grid() geometry manager
+frm_entry.grid(row=0, column=0, padx=10)
+btn_convert.grid(row=0, column=1, pady=10)
+lbl_result.grid(row=0, column=2, padx=10)
+
+# Run the application
+window.mainloop()

demo/api_client/basic.py

@@ -0,0 +1,10 @@
+import requests
+
+endpoint = "https://httpbin.org/status/200"
+endpoint = "https://httpbin.org/anything"
+endpoint = "http://localhost:8000/api"
+
+get_response = requests.get(endpoint) # HTTP get request
+print(get_response.text)
+
+# REST API -> Web API

demo/demo/urls.py

@@ -17,9 +17,11 @@ Including another URLconf
 from django.contrib import admin
 from django.urls import path,include
 from migration.views import migration_home
+from migration.views import api_home
 
 urlpatterns = [
     path('admin/', admin.site.urls),
     path('', include("migration.urls")),
     path('migration/', migration_home),
+    path('api/', api_home),
 ]

demo/migration/models.py

@@ -1,3 +1,7 @@
 from django.db import models
 
 # Create your models here.
+class Product(models.Model):
+    title = models.CharField(max_length=120)
+    content= models.TextField(blank=True, null=True)
+    price = models.DecimalField(max_digits=15,decimal_places=2,default=99.99)

demo/migration/urls.py

@@ -4,4 +4,5 @@ from . import views
 urlpatterns = [
 path("", views.index, name= "index"),
 path("", views.migration_home, name= "migration"),
+path("", views.api_home, name= "api"),
 ]

demo/migration/views.py

@@ -1,11 +1,28 @@
 from django.shortcuts import render
-from django.http import HttpResponse
+from django.http import HttpResponse, JsonResponse
 
 def index(response):
       return HttpResponse("Welcome to siMed Migration")
 
 def migration_home(request):
       return render(request,'migration.html')
+
+
    
+def api_home(request,endpoint, params={"message": "Your JSON Repsonse"}):
+      body = request.body
+      data = {}
+      try:
+            data = json.loads(body)
+      except:
+         pass
+      print(request.GET)
+      print(data)
+      data['params'] = dict(request.GET)
+      data['headers'] = dict(request.headers)
+      data['content_type'] = request.content_type
+      return JsonResponse(data)
+     
+ ##return JsonResponse()
 
 

docker-compose-queue.yml

@@ -0,0 +1,22 @@
+version: '3'
+services:
+  rabbitmq:
+    image: rabbitmq:management
+    container_name: mq
+    restart: unless-stopped
+    environment:
+      - RABBITMQ_DEFAULT_USER=mqadmin
+      - RABBITMQ_DEFAULT_PASS=3Mnj29jKBsFybc    
+    ports:
+      # The standard AMQP protocol port
+      - '5672:5672'
+      # HTTP management UI
+      - '15672:15672'
+    volumes:
+      - ./queue/data/:/var/lib/rabbitmq/
+      - ./queue/log/:/var/log/rabbitmq/
+    networks:
+      - ametiq
+networks:
+  ametiq:
+    external: true

docker-compose.yml

@@ -7,6 +7,7 @@ services:
       context: .
     ports:
       - "9000:8000"
+      - "7070:8080"
     networks:
       - ametiq
     restart: unless-stopped

queue/data/.erlang.cookie

@@ -0,0 +1 @@
+EASVPCBJZKYPFVDBKWIE

queue/data/mnesia/rabbit@5c60bc6971d3-feature_flags

@@ -0,0 +1,17 @@
+[classic_mirrored_queue_version,
+ classic_queue_type_delivery_support,
+ direct_exchange_routing_v2,
+ drop_unroutable_metric,
+ empty_basic_get_metric,
+ feature_flags_v2,
+ implicit_default_bindings,
+ listener_records_in_ets,
+ maintenance_mode_status,
+ quorum_queue,
+ restart_streams,
+ stream_queue,
+ stream_sac_coordinator_unblock_group,
+ stream_single_active_consumer,
+ tracking_records_in_ets,
+ user_limits,
+ virtual_host_metadata].

queue/data/mnesia/rabbit@5c60bc6971d3/cluster_nodes.config

@@ -0,0 +1 @@
+{[rabbit@5c60bc6971d3],[rabbit@5c60bc6971d3]}.

queue/data/mnesia/rabbit@5c60bc6971d3/coordination/rabbit@5c60bc6971d3/00000001.wal

@@ -0,0 +1 @@
+RAWA

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.config

@@ -0,0 +1,2 @@
+%% This file is auto-generated! Edit at your own risk!
+{segment_entry_count, 2048}.

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/.vhost

@@ -0,0 +1 @@
+/

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_persistent/clean.dot

@@ -0,0 +1,2 @@
+{client_refs,[]}.
+{index_module,rabbit_msg_store_ets_index}.

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/msg_store_transient/clean.dot

@@ -0,0 +1,2 @@
+{client_refs,[]}.
+{index_module,rabbit_msg_store_ets_index}.

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5BY898XLEGEBFE6E2YXLPN9EB/.queue_name

@@ -0,0 +1,2 @@
+VHOST: /
+QUEUE: AllInfo

queue/data/mnesia/rabbit@5c60bc6971d3/msg_stores/vhosts/628WB79CIFDYO9LJI6DKMI09L/queues/5DFCY53MTYI7QMR2T268HJ0JX/.queue_name

@@ -0,0 +1,2 @@
+VHOST: /
+QUEUE: PartInfo

queue/data/mnesia/rabbit@5c60bc6971d3/node-type.txt

@@ -0,0 +1 @@
+disc.

queue/data/mnesia/rabbit@5c60bc6971d3/nodes_running_at_shutdown

@@ -0,0 +1 @@
+[rabbit@5c60bc6971d3].

queue/data/mnesia/rabbit@5c60bc6971d3/quorum/rabbit@5c60bc6971d3/00000001.wal

@@ -0,0 +1 @@
+RAWA

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_queue.DCD

@@ -0,0 +1 @@
+
cXM

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_durable_route.DCD

@@ -0,0 +1 @@
+
cXM

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_serial

@@ -0,0 +1 @@
+1.

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_topic_permission.DCD

@@ -0,0 +1 @@
+
cXM

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user.DCD

@@ -0,0 +1 @@
+
cXM

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_user_permission.DCD

@@ -0,0 +1 @@
+
cXM

queue/data/mnesia/rabbit@5c60bc6971d3/rabbit_vhost.DCD

@@ -0,0 +1 @@
+
cXM