src/app/_services/output.service.spec.ts

@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { OutputService } from './output.service';
+
+describe('OutputService', () => {
+  let service: OutputService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(OutputService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});

src/app/_services/output.service.ts

@@ -1,3 +1,20 @@
+import { Injectable } from '@angular/core';
+import { MQTTEntity } from '../_models/mqtt_base';
+import { GeneratorService } from './generator.service';
+
+@Injectable({
+  providedIn: 'root',
+})
+export class OutputService {
+  constructor(private generatorService: GeneratorService) {}
+  basecode: {} = { 'mqtt-init': '{testestsdsdf}' };
+  output: boolean = false;
+  _integrated_output: boolean = false;
+  _device_entity_cached: { entity: MQTTEntity; listlen: number } = {
+    entity: new MQTTEntity(),
+    listlen: 0,
+  };
+
   get device_entity(): MQTTEntity {
     if (
       this._device_entity_cached.listlen ===
@@ -17,3 +34,86 @@
     console.log(this._device_entity_cached);
     return entites[0];
   }
+
+  get seperate_outputs(): boolean {
+    return this.output && !this._integrated_output;
+  }
+
+  get integrated_output(): boolean {
+    return this.output && this._integrated_output;
+  }
+
+  set integrated_output(value: boolean) {
+    this._integrated_output = value;
+  }
+
+  getDiscoveryString(entity: MQTTEntity, escaped = false): string | {} {
+    let str = entity.toJSON();
+    if (this.generatorService.use_device) {
+      str['dev'] = this.generatorService.device.toJSON(
+        entity.uniq_id == this.device_entity.uniq_id
+      );
+    }
+
+    if (escaped) {
+      return JSON.stringify(str).replaceAll('"', '\\"');
+    }
+    return str;
+  }
+
+  getDiscoveryTopic(entity: MQTTEntity): string {
+    return join(
+      '/',
+      'homeassistant',
+      entity.ent_type,
+      entity.display_name,
+      'config'
+    ).toLowerCase();
+  }
+
+  integrateCode(): string {
+    let mqtt_init =
+      '#include <EspMQTTClient.h>\n\nEspMQTTClient mqtt(\n\t"wifi_name",\n\t"wifi_pw",\n\t"broker_ip",\n\t"mqtt_acc",\n\t"mqtt_pw",\n\t"device_name",\n\t"mqtt_port"\n);\n';
+    let setup = 'void setup(){\nclient.setMaxPacketSize(512);\n}\n';
+    let onConnectStart = 'void onConnectionEstablished() {\n\tdelay=10\n';
+    let onConnectEnd = '\tmqtt.loop()\n}\n';
+    let loop = 'void loop() {\n\tmqtt.loop();\n\tdelay(100);\n}';
+
+    let discoveryMsg: string[] = [];
+    let publishTopics: string[] = [];
+    for (let [index, entity] of Array.from(
+      this.generatorService.created_enteties
+    ).entries()) {
+      discoveryMsg.push('\t// Sending discovery for Entity ' + index);
+      discoveryMsg.push(
+        `\tmqtt.publish(${this.getDiscoveryTopic(
+          entity
+        )}, ${this.getDiscoveryString(entity, true)}, true);\n`
+      );
+
+      publishTopics.push(...entity.publish_topics(index));
+      publishTopics.push();
+    }
+    publishTopics.push('\n');
+    return (
+      mqtt_init +
+      '\n' +
+      publishTopics.join('\n') +
+      setup +
+      onConnectStart +
+      discoveryMsg.join('\n') +
+      onConnectEnd +
+      loop
+    );
+  }
+}
+
+function join(seperator = '/', first: string, ...args: string[]): string {
+  let result = '';
+  for (let str of args) {
+    if (str == '') continue;
+    result += seperator + str;
+  }
+  if (first == '') return result.slice(1);
+  return first + result;
+}

src/app/output/output.component.css

@@ -0,0 +1,5 @@
+pre {
+  max-width: calc(50vw - 1rem);
+  overflow-x: scroll;
+  text-wrap: nowrap;
+}

src/app/output/output.component.html

@@ -0,0 +1,5 @@
+<div>
+    <h2>Code Output</h2>
+    <pre>{{outputService.integrateCode()}}</pre>
+    <p></p>
+</div>

src/app/output/output.component.spec.ts

@@ -0,0 +1,23 @@
+import { ComponentFixture, TestBed } from '@angular/core/testing';
+
+import { OutputComponent } from './output.component';
+
+describe('OutputComponent', () => {
+  let component: OutputComponent;
+  let fixture: ComponentFixture<OutputComponent>;
+
+  beforeEach(async () => {
+    await TestBed.configureTestingModule({
+      declarations: [OutputComponent]
+    })
+    .compileComponents();
+    
+    fixture = TestBed.createComponent(OutputComponent);
+    component = fixture.componentInstance;
+    fixture.detectChanges();
+  });
+
+  it('should create', () => {
+    expect(component).toBeTruthy();
+  });
+});

src/app/output/output.component.ts

@@ -0,0 +1,11 @@
+import { Component } from '@angular/core';
+import { OutputService } from '../_services/output.service';
+
+@Component({
+  selector: 'app-output',
+  templateUrl: './output.component.html',
+  styleUrl: './output.component.css',
+})
+export class OutputComponent {
+  constructor(public outputService: OutputService) {}
+}