DNS: introduce TXT support

Author: gmelikov

genesis_core/tests/functional/service/dns/test_pdns.py

@@ -171,3 +171,54 @@ def test_a_record(
         response = client.delete(url)
 
         assert response.status_code == 204
+
+    def test_txt_record(
+        self,
+        user_api_client: iam_clients.GenesisCoreTestRESTClient,
+        auth_user_admin: iam_clients.GenesisCoreAuth,
+        domain1: tp.Dict,
+        pdns_server: int | None,
+    ):
+        client = user_api_client(auth_user_admin)
+
+        data = {
+            "uuid": str(sys_uuid.uuid4()),
+            "type": "TXT",
+            "ttl": 0,
+            "record": {"kind": "TXT", "name": "test", "content": "a" * 5000},
+        }
+
+        url = client.build_collection_uri(
+            ["dns", "domains", domain1["uuid"], "records"]
+        )
+
+        response = client.post(url, json=data)
+        output = response.json()
+
+        assert response.status_code == 201
+        assert self._cmp_shallow(data, output)
+
+        url = client.build_resource_uri(
+            ["dns", "domains", domain1["uuid"], "records", data["uuid"]]
+        )
+
+        response = client.get(url)
+        record = response.json()
+        assert response.status_code == 200
+        assert self._cmp_shallow(data, record)
+
+        if pdns_server:
+            res = dns.resolver.make_resolver_at("127.0.0.1", port=pdns_server)
+            answer = res.resolve(f"test.{DEF_DOMAIN}", "TXT")
+
+            assert len(answer) == 1
+            # TXT records may not fit in one UDP frame, so there'll be many
+            #  strings inside
+            assert (
+                "".join([i.decode() for i in answer[0].strings]) == "a" * 5000
+            )
+
+        # Delete
+        response = client.delete(url)
+
+        assert response.status_code == 204

genesis_core/user_api/dns/dm/models.py

@@ -14,6 +14,8 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
+import re
+
 from oslo_config import cfg
 from restalchemy.common import contexts
 from restalchemy.common import exceptions
@@ -112,7 +114,7 @@ def get_name(self, domain) -> str:
         )
 
     def get_content(self, domain) -> str:
-        return str(self.address)
+        return str(self.content)
 
 
 class ARecord(AbstractRecord):
@@ -127,6 +129,9 @@ class ARecord(AbstractRecord):
         required=True,
     )
 
+    def get_content(self, domain) -> str:
+        return str(self.address)
+
 
 class SOARecord(AbstractRecord):
     KIND = "SOA"
@@ -149,12 +154,26 @@ def get_content(self, domain) -> str:
         return f"{self.primary_dns} {domain.name} {self.serial} {self.refresh} {self.retry} {self.expire} {self.ttl}"
 
 
+class TXTRecord(AbstractRecord):
+    KIND = "TXT"
+
+    name = properties.property(
+        types_network.RecordName(),
+        required=True,
+    )
+    content = properties.property(
+        # Restrict newline and length
+        types.BaseCompiledRegExpType(re.compile(r"^([^\n]{1,8192})$")),
+        required=True,
+    )
+
+
 class Record(CommonModel):
     __tablename__ = "dns_records"
     domain = relationships.relationship(Domain, required=True)
     domain_id = properties.property(types.Integer())
     type = properties.property(
-        types.Enum(("A", "SOA")), # "AAAA", "CNAME", "MX", "TXT",
+        types.Enum(("A", "SOA", "TXT")),  # "AAAA", "CNAME", "MX",
         read_only=True,
         required=True,
     )
@@ -165,6 +184,7 @@ class Record(CommonModel):
         types_dynamic.KindModelSelectorType(
             types_dynamic.KindModelType(ARecord),
             types_dynamic.KindModelType(SOARecord),
+            types_dynamic.KindModelType(TXTRecord),
         ),
         required=True,
     )