1
2
3
4
5
6
7
8
9 package mlkem
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26 import (
27 "bytes"
28 "crypto/internal/fips140"
29 "crypto/internal/fips140/drbg"
30 "crypto/internal/fips140/sha3"
31 "crypto/internal/fips140/subtle"
32 "errors"
33 )
34
35 const (
36
37 n = 256
38 q = 3329
39
40
41
42 encodingSize12 = n * 12 / 8
43 encodingSize11 = n * 11 / 8
44 encodingSize10 = n * 10 / 8
45 encodingSize5 = n * 5 / 8
46 encodingSize4 = n * 4 / 8
47 encodingSize1 = n * 1 / 8
48
49 messageSize = encodingSize1
50
51 SharedKeySize = 32
52 SeedSize = 32 + 32
53 )
54
55
56 const (
57 k = 3
58
59 CiphertextSize768 = k*encodingSize10 + encodingSize4
60 EncapsulationKeySize768 = k*encodingSize12 + 32
61 decapsulationKeySize768 = k*encodingSize12 + EncapsulationKeySize768 + 32 + 32
62 )
63
64
65 const (
66 k1024 = 4
67
68 CiphertextSize1024 = k1024*encodingSize11 + encodingSize5
69 EncapsulationKeySize1024 = k1024*encodingSize12 + 32
70 decapsulationKeySize1024 = k1024*encodingSize12 + EncapsulationKeySize1024 + 32 + 32
71 )
72
73
74
75 type DecapsulationKey768 struct {
76 d [32]byte
77 z [32]byte
78
79 ρ [32]byte
80 h [32]byte
81
82 encryptionKey
83 decryptionKey
84 }
85
86
87
88
89 func (dk *DecapsulationKey768) Bytes() []byte {
90 var b [SeedSize]byte
91 copy(b[:], dk.d[:])
92 copy(b[32:], dk.z[:])
93 return b[:]
94 }
95
96
97
98
99
100
101 func TestingOnlyExpandedBytes768(dk *DecapsulationKey768) []byte {
102 b := make([]byte, 0, decapsulationKeySize768)
103
104
105 for i := range dk.s {
106 b = polyByteEncode(b, dk.s[i])
107 }
108
109
110 for i := range dk.t {
111 b = polyByteEncode(b, dk.t[i])
112 }
113 b = append(b, dk.ρ[:]...)
114
115
116 b = append(b, dk.h[:]...)
117 b = append(b, dk.z[:]...)
118
119 return b
120 }
121
122
123
124 func (dk *DecapsulationKey768) EncapsulationKey() *EncapsulationKey768 {
125 return &EncapsulationKey768{
126 ρ: dk.ρ,
127 h: dk.h,
128 encryptionKey: dk.encryptionKey,
129 }
130 }
131
132
133
134 type EncapsulationKey768 struct {
135 ρ [32]byte
136 h [32]byte
137 encryptionKey
138 }
139
140
141 func (ek *EncapsulationKey768) Bytes() []byte {
142
143 b := make([]byte, 0, EncapsulationKeySize768)
144 return ek.bytes(b)
145 }
146
147 func (ek *EncapsulationKey768) bytes(b []byte) []byte {
148 for i := range ek.t {
149 b = polyByteEncode(b, ek.t[i])
150 }
151 b = append(b, ek.ρ[:]...)
152 return b
153 }
154
155
156 type encryptionKey struct {
157 t [k]nttElement
158 a [k * k]nttElement
159 }
160
161
162 type decryptionKey struct {
163 s [k]nttElement
164 }
165
166
167
168 func GenerateKey768() (*DecapsulationKey768, error) {
169
170 dk := &DecapsulationKey768{}
171 return generateKey(dk)
172 }
173
174 func generateKey(dk *DecapsulationKey768) (*DecapsulationKey768, error) {
175 fipsSelfTest()
176 var d [32]byte
177 drbg.Read(d[:])
178 var z [32]byte
179 drbg.Read(z[:])
180 kemKeyGen(dk, &d, &z)
181 fips140.PCT("ML-KEM PCT", func() error { return kemPCT(dk) })
182 fips140.RecordApproved()
183 return dk, nil
184 }
185
186
187
188 func GenerateKeyInternal768(d, z *[32]byte) *DecapsulationKey768 {
189 fipsSelfTest()
190 dk := &DecapsulationKey768{}
191 kemKeyGen(dk, d, z)
192 return dk
193 }
194
195
196
197 func NewDecapsulationKey768(seed []byte) (*DecapsulationKey768, error) {
198
199 dk := &DecapsulationKey768{}
200 return newKeyFromSeed(dk, seed)
201 }
202
203 func newKeyFromSeed(dk *DecapsulationKey768, seed []byte) (*DecapsulationKey768, error) {
204 fipsSelfTest()
205 if len(seed) != SeedSize {
206 return nil, errors.New("mlkem: invalid seed length")
207 }
208 d := (*[32]byte)(seed[:32])
209 z := (*[32]byte)(seed[32:])
210 kemKeyGen(dk, d, z)
211 fips140.RecordApproved()
212 return dk, nil
213 }
214
215
216
217
218
219
220
221
222 func TestingOnlyNewDecapsulationKey768(b []byte) (*DecapsulationKey768, error) {
223 if len(b) != decapsulationKeySize768 {
224 return nil, errors.New("mlkem: invalid NIST decapsulation key length")
225 }
226
227 dk := &DecapsulationKey768{}
228 for i := range dk.s {
229 var err error
230 dk.s[i], err = polyByteDecode[nttElement](b[:encodingSize12])
231 if err != nil {
232 return nil, errors.New("mlkem: invalid secret key encoding")
233 }
234 b = b[encodingSize12:]
235 }
236
237 ek, err := NewEncapsulationKey768(b[:EncapsulationKeySize768])
238 if err != nil {
239 return nil, err
240 }
241 dk.ρ = ek.ρ
242 dk.h = ek.h
243 dk.encryptionKey = ek.encryptionKey
244 b = b[EncapsulationKeySize768:]
245
246 if !bytes.Equal(dk.h[:], b[:32]) {
247 return nil, errors.New("mlkem: inconsistent H(ek) in encoded bytes")
248 }
249 b = b[32:]
250
251 copy(dk.z[:], b)
252
253
254
255
256
257 drbg.Read(dk.d[:])
258
259 return dk, nil
260 }
261
262
263
264
265
266
267 func kemKeyGen(dk *DecapsulationKey768, d, z *[32]byte) {
268 dk.d = *d
269 dk.z = *z
270
271 g := sha3.New512()
272 g.Write(d[:])
273 g.Write([]byte{k})
274 G := g.Sum(make([]byte, 0, 64))
275 ρ, σ := G[:32], G[32:]
276 dk.ρ = [32]byte(ρ)
277
278 A := &dk.a
279 for i := byte(0); i < k; i++ {
280 for j := byte(0); j < k; j++ {
281 A[i*k+j] = sampleNTT(ρ, j, i)
282 }
283 }
284
285 var N byte
286 s := &dk.s
287 for i := range s {
288 s[i] = ntt(samplePolyCBD(σ, N))
289 N++
290 }
291 e := make([]nttElement, k)
292 for i := range e {
293 e[i] = ntt(samplePolyCBD(σ, N))
294 N++
295 }
296
297 t := &dk.t
298 for i := range t {
299 t[i] = e[i]
300 for j := range s {
301 t[i] = polyAdd(t[i], nttMul(A[i*k+j], s[j]))
302 }
303 }
304
305 H := sha3.New256()
306 ek := dk.EncapsulationKey().Bytes()
307 H.Write(ek)
308 H.Sum(dk.h[:0])
309 }
310
311
312
313
314
315
316
317
318
319 func kemPCT(dk *DecapsulationKey768) error {
320 ek := dk.EncapsulationKey()
321 K, c := ek.Encapsulate()
322 K1, err := dk.Decapsulate(c)
323 if err != nil {
324 return err
325 }
326 if subtle.ConstantTimeCompare(K, K1) != 1 {
327 return errors.New("mlkem: PCT failed")
328 }
329 return nil
330 }
331
332
333
334
335
336 func (ek *EncapsulationKey768) Encapsulate() (sharedKey, ciphertext []byte) {
337
338 var cc [CiphertextSize768]byte
339 return ek.encapsulate(&cc)
340 }
341
342 func (ek *EncapsulationKey768) encapsulate(cc *[CiphertextSize768]byte) (sharedKey, ciphertext []byte) {
343 fipsSelfTest()
344 var m [messageSize]byte
345 drbg.Read(m[:])
346
347
348 fips140.RecordApproved()
349 return kemEncaps(cc, ek, &m)
350 }
351
352
353
354 func (ek *EncapsulationKey768) EncapsulateInternal(m *[32]byte) (sharedKey, ciphertext []byte) {
355 fipsSelfTest()
356 cc := &[CiphertextSize768]byte{}
357 return kemEncaps(cc, ek, m)
358 }
359
360
361
362
363 func kemEncaps(cc *[CiphertextSize768]byte, ek *EncapsulationKey768, m *[messageSize]byte) (K, c []byte) {
364 g := sha3.New512()
365 g.Write(m[:])
366 g.Write(ek.h[:])
367 G := g.Sum(nil)
368 K, r := G[:SharedKeySize], G[SharedKeySize:]
369 c = pkeEncrypt(cc, &ek.encryptionKey, m, r)
370 return K, c
371 }
372
373
374
375 func NewEncapsulationKey768(encapsulationKey []byte) (*EncapsulationKey768, error) {
376
377 ek := &EncapsulationKey768{}
378 return parseEK(ek, encapsulationKey)
379 }
380
381
382
383
384
385 func parseEK(ek *EncapsulationKey768, ekPKE []byte) (*EncapsulationKey768, error) {
386 if len(ekPKE) != EncapsulationKeySize768 {
387 return nil, errors.New("mlkem: invalid encapsulation key length")
388 }
389
390 h := sha3.New256()
391 h.Write(ekPKE)
392 h.Sum(ek.h[:0])
393
394 for i := range ek.t {
395 var err error
396 ek.t[i], err = polyByteDecode[nttElement](ekPKE[:encodingSize12])
397 if err != nil {
398 return nil, err
399 }
400 ekPKE = ekPKE[encodingSize12:]
401 }
402 copy(ek.ρ[:], ekPKE)
403
404 for i := byte(0); i < k; i++ {
405 for j := byte(0); j < k; j++ {
406 ek.a[i*k+j] = sampleNTT(ek.ρ[:], j, i)
407 }
408 }
409
410 return ek, nil
411 }
412
413
414
415
416
417 func pkeEncrypt(cc *[CiphertextSize768]byte, ex *encryptionKey, m *[messageSize]byte, rnd []byte) []byte {
418 var N byte
419 r, e1 := make([]nttElement, k), make([]ringElement, k)
420 for i := range r {
421 r[i] = ntt(samplePolyCBD(rnd, N))
422 N++
423 }
424 for i := range e1 {
425 e1[i] = samplePolyCBD(rnd, N)
426 N++
427 }
428 e2 := samplePolyCBD(rnd, N)
429
430 u := make([]ringElement, k)
431 for i := range u {
432 var uHat nttElement
433 for j := range r {
434
435 uHat = polyAdd(uHat, nttMul(ex.a[j*k+i], r[j]))
436 }
437 u[i] = polyAdd(e1[i], inverseNTT(uHat))
438 }
439
440 μ := ringDecodeAndDecompress1(m)
441
442 var vNTT nttElement
443 for i := range ex.t {
444 vNTT = polyAdd(vNTT, nttMul(ex.t[i], r[i]))
445 }
446 v := polyAdd(polyAdd(inverseNTT(vNTT), e2), μ)
447
448 c := cc[:0]
449 for _, f := range u {
450 c = ringCompressAndEncode10(c, f)
451 }
452 c = ringCompressAndEncode4(c, v)
453
454 return c
455 }
456
457
458
459
460
461 func (dk *DecapsulationKey768) Decapsulate(ciphertext []byte) (sharedKey []byte, err error) {
462 fipsSelfTest()
463 if len(ciphertext) != CiphertextSize768 {
464 return nil, errors.New("mlkem: invalid ciphertext length")
465 }
466 c := (*[CiphertextSize768]byte)(ciphertext)
467
468
469
470 return kemDecaps(dk, c), nil
471 }
472
473 var testingOnlyRejectionOutcome func(int)
474
475
476
477
478 func kemDecaps(dk *DecapsulationKey768, c *[CiphertextSize768]byte) (K []byte) {
479 fips140.RecordApproved()
480 m := pkeDecrypt(&dk.decryptionKey, c)
481 g := sha3.New512()
482 g.Write(m[:])
483 g.Write(dk.h[:])
484 G := g.Sum(make([]byte, 0, 64))
485 Kprime, r := G[:SharedKeySize], G[SharedKeySize:]
486 J := sha3.NewShake256()
487 J.Write(dk.z[:])
488 J.Write(c[:])
489 Kout := make([]byte, SharedKeySize)
490 J.Read(Kout)
491 var cc [CiphertextSize768]byte
492 c1 := pkeEncrypt(&cc, &dk.encryptionKey, (*[32]byte)(m), r)
493
494 if testingOnlyRejectionOutcome != nil {
495 testingOnlyRejectionOutcome(subtle.ConstantTimeCompare(c[:], c1))
496 }
497
498 subtle.ConstantTimeCopy(subtle.ConstantTimeCompare(c[:], c1), Kout, Kprime)
499 return Kout
500 }
501
502
503
504
505
506 func pkeDecrypt(dx *decryptionKey, c *[CiphertextSize768]byte) []byte {
507 u := make([]ringElement, k)
508 for i := range u {
509 b := (*[encodingSize10]byte)(c[encodingSize10*i : encodingSize10*(i+1)])
510 u[i] = ringDecodeAndDecompress10(b)
511 }
512
513 b := (*[encodingSize4]byte)(c[encodingSize10*k:])
514 v := ringDecodeAndDecompress4(b)
515
516 var mask nttElement
517 for i := range dx.s {
518 mask = polyAdd(mask, nttMul(dx.s[i], ntt(u[i])))
519 }
520 w := polySub(v, inverseNTT(mask))
521
522 return ringCompressAndEncode1(nil, w)
523 }
524
View as plain text